Redis PUBLISH命令

Redis的PUBLISH命令用于向指定的频道(channel)发布一条消息(message)，所有订阅该频道的客户端都能接收到这条消息。其基本格式为：PUBLISH channel message。

PUBLISH命令是Redis发布/订阅(pub/sub)功能的基础命令之一，常用于实现聊天室、实时消息推送等场景。下面就来详细讲解它的使用方法及示例：

标题

命令格式

PUBLISH channel message

参数说明

• channel：要发布消息的频道名称。
• message：要发布的消息内容。

使用方法

1. 在Redis-cli客户端中使用PUBLISH命令，例如向名为“chat_room”的频道发布一条“Hello World！”的消息：

PUBLISH chat_room "Hello World！"

1. 也可以在程序中使用Redis的客户端库，比如Python的redis模块，实现PUBLISH命令的调用，如下所示：

import redis
r = redis.Redis(host='localhost', port=6379, decode_responses=True)
r.publish('chat_room', 'Hello World！')

示例说明

1. 聊天室实现
   假设有一个在线聊天室，多个用户可以在该聊天室中发送和接收消息，那么在聊天室服务器中，可以通过调用PUBLISH命令将用户输入的消息实时广播到所有订阅了该频道的客户端中：

// 服务器端
import redis
import asyncio

async def handle(reader, writer):
    addr = writer.get_extra_info('peername')
    print('Accepted connection from {}'.format(addr))
    p = await redis.ConnectionPool.create(host='localhost', port=6379, db=0)
    r = redis.Redis(connection_pool=p)
    channel = 'chat_room'
    while True:
        data = await reader.read(1024)
        message = data.decode('utf-8').strip()
        if not message:
            break
        r.publish(channel, message)
    print('Close the client socket')
    writer.close()

async def main():
    server = await asyncio.start_server(handle, 'localhost', 8888)
    addr = server.sockets[0].getsockname()
    print(f'Serving on {addr}')
    async with server:
        await server.serve_forever()

asyncio.run(main())

// 客户端
import asyncio
import sys

async def tcp_echo_client():
    reader, writer = await asyncio.open_connection('localhost', 8888)

    while True:
        message = input("> ")
        if not message:
            break
        writer.write(message.encode())
        await writer.drain()

    print('Close the socket')
    writer.close()
    await writer.wait_closed()

async def main():
    await tcp_echo_client()

asyncio.run(main())

多个客户端连接到服务器后，输入的消息将被实时发布到订阅了该频道的其他客户端中。

1. 实时数据更新
   比如一个在线商城，当有商品库存更新时，需要及时通知所有客户端，可以通过调用PUBLISH命令实现该功能：

import redis
import time

r = redis.Redis(host='localhost', port=6379, decode_responses=True)
channel = 'product_update'
while True:
    # 假设每隔5秒自动刷新一次页面，查询库存
    stock = query_stock()
    r.publish(channel, stock)
    time.sleep(5)

在客户端中订阅该频道，就可以实时接收到商品库存的变化信息，从而及时更新页面数据。