发布订阅Redis无注册消息发布与订阅机制（redis没有注册消息）

Redis是一款高性能的Key-Value存储系统，同时也支持发布订阅模型。发布订阅模型是一种无注册的消息发布与订阅机制，对于分布式系统中的各种消息传递场景具有很大的作用。

当一个系统需要将某些信息发布出去，并且让其它系统订阅这些信息时，一般的解决方案是在系统中添加注册机制，让订阅者在发布者处向其注册，以便获得发布者发布的信息。这种方案的实现复杂度较高，而且会增加系统的耦合性。

Redis 的发布订阅模型避免了这种情况。发布者将消息发布到 Redis 的某个频道中，订阅者只需要向 Redis 订阅相应的频道，就能接收到发布者发布的消息。两者直接并没有直接的交互，解耦性非常良好。

下面我们演示一下 Redis 发布订阅模型的实现方法：

先安装 Redis 的 Python 客户端。

pip install redis

创建发布者和订阅者

在 Python 中，我们可以很容易地创建发布者和订阅者。如下：

“` Python

import redis

redis_conn = redis.StrictRedis(host=’localhost’, port=6379, db=0)

def sub(channel):

pubsub = redis_conn.pubsub()

pubsub.subscribe(channel)

for msg in pubsub.listen():

print(msg)

def pub(channel, message):

redis_conn.publish(channel, message)

使用 pub 和 sub 函数分别创建发布者和订阅者。

接下来，我们分别用 pub 和 sub 函数创建生产者和消费者：

``` Python
pub('test', 'hello, world!')
sub('test')

以上代码是在本地环境下，向订阅 channel 是 test 的客户端发送消息 hello, world!

启动订阅者之后，就会立刻接收到消息，输出为：

{‘channel’: b’test’, ‘data’: b’hello, world!’, ‘pattern’: None, ‘type’: ‘message’}

在消息传递环节中，由于 Redis 使用了消息队列的概念，所以消息是支持堆积的，即当没有订阅者时，消息会被缓存下来，直到订阅者上线后主动读取。这样就可以完美地解决如系统弹性伸缩等场景下，订阅者不在线的问题。

总结

在大数据量，高吞吐量并发环境下，使用高性能的消息传递机制可以有效提高系统的稳定性和性能。发布订阅模型是一种无注册的消息发布与订阅机制，非常适用于像消息队列、即时通讯等场景。

Redis 的发布订阅模型为分布式系统消息传递提供了非常好的解决方案，具有高性能、低耦合性等优点。同时，Redis 的客户端库和支持多种编程语言，开发和使用非常灵活和方便。