Redis实现轻松消息总线系统（用redis做消息总线）

Redis作为一款强大的内存数据库，它在一定程度上可以方便我们实现企业消息总线系统。一般消息总线系统由消息代理产生者和消费者组成，利用Redis的发布/订阅功能，可以比较容易实现消息发布和订阅的功能。

以下通过代码和注释来演示具体的实现过程：

“`java

// 创建消息代理产生者

public class Producer {

private Jedis jedis;

public Producer(Jedis jedis) {

this.jedis = jedis;

}

// 发布消息

public void publish(String channel, String message) {

jedis.publish(channel, message);

}

}

// 创建消息代理消费者

public class Consumer {

private Jedis jedis;

public Consumer(Jedis jedis) {

this.jedis = jedis;

}

// 订阅消息

public List subscribe(String channel) {

JedisPubSub jedisPubSub = new JedisPubSub() {

@Override

public void onMessage(String channel, String message) {

System.out.println(“收到新消息：” + message);

}

};

jedis.subscribe(jedisPubSub, channel);

return jedisPubSub.getSubscriptionMessageList();

}

}

// 使用代码

public class RedisMessageBus {

public static void mn(String[] args) {

Jedis jedis = new Jedis(“localhost”);

Producer producer = new Producer(jedis);

// 向app消息总线发布消息

producer.publish(“app”, “app有新的消息发来”);

Consumer consumer = new Consumer(jedis);

// 向app消息总线订阅消息

List list = consumer.subscribe(“app”);

System.out.println(“收到的消息列表为：” + list);

}

}

以上代码中，利用Jedis发布/订阅实现了Redis作为消息总线系统的实现，Producer用于发布消息，Consumer用于订阅消息，JedisPubSub用于接收并处理信息，在处理完成后把消息返回，最后在主函数中调取消息，从而一better实现消息总线系统。

总结一下利用Redis实现消息总线系统的优点：

优点：

1.Redis的读写性能极高，能够满足消息总线系统的高并发场景；

2.节省硬盘空间，Redis数据存储在内存里，内存容量大小决定数据存储量，而不用占用磁盘空间；

3.消息发送延迟低，因为Redis是内存存储，没有磁盘I/O，所以在发布消息时速度块比磁盘存储的方式快得多；

4.方便的发布/订阅功能，利用Redis的发布/订阅功能可以比较容易实现消息发布和订阅的功能。

缺点：

因为数据是存储在内存里，系统服务重启时无法保留消息，不适合消息持久化。

可以看出，通过Redis可以轻松搭建消息总线系统，能够比较好地解决高并发场景下信息传递的问题。