# 引入Redis模块
import redis

# 创建Redis连接
r = redis.Redis(host='localhost', port=6379, db=0)

# 发布消息
def publish_message(channel, message):
    r.publish(channel, message)

# 订阅消息
def handle_message(message):
    print("收到消息：", message)

def subscribe_message(channel):
    pubsub = r.pubsub()
    pubsub.subscribe(channel)
    for message in pubsub.listen():
        if message['type'] == 'message':
            handle_message(message['data'])

# 发送实时消息
if __name__ == '__main__':
    channel = 'realtime_channel'
    message = 'Hello, Redis!'
    publish_message(channel, message)

在上述示例中，我们使用Python的Redis模块连接到Redis服务器，并定义了消息发布和处理的函数。publish_message函数用于发布消息，subscribe_message函数用于订阅消息，handle_message函数用于处理接收到的消息。

在主函数中，我们创建了一个名为realtime_channel的频道，并向该频道发布了一条消息。通过订阅realtime_channel频道，我们可以接收实时消息，并在handle_message函数中进行相应的处理。

通过Redis的发布/订阅模式，我们可以实现实时消息的推送，并在分布式系统中方便地进行消息传递。这种机制可以广泛应用于各种实时通信、消息推送和事件通知场景中。