ZeroMQ消息Python版：pyzmq发布响应模式（ Pub-Sub模式）

不念不忘少年蓝@ 2022-12-28 06:11 87阅读 0赞

服务端：

import zmq
    import sys
    import time
    
    
    def main():
        context = zmq.Context()
        skt = context.socket(zmq.PUB)
        skt.bind("tcp://127.0.0.1:8888")
    
        while True:
            try:
                time.sleep(3)
    
    
                data = bytes('服务器时间:@' + time.strftime("%Y-%m-%d %H:%M:%S %a"), encoding='utf-8')
    
                skt.send(data)
    
                print('发送消息', data.decode('utf-8'))
            except Exception as e:
                print('异常:', e)
                sys.exit()
    
    
    if __name__ == '__main__':
        main()

客户端：

import zmq
    import sys
    
    
    def main():
        context = zmq.Context()
        print("连接服务器...")
        skt = context.socket(zmq.SUB)
        skt.connect("tcp://127.0.0.1:8888")
    
        skt.setsockopt(zmq.SUBSCRIBE, '服务器时间'.encode('utf-8'))  # 只订阅 服务器时间 开头的消息
    
        while True:
            response = skt.recv().decode('utf-8')
            print("接收到服务器数据: ", response)
        sys.exit()
    
    
    if __name__ == '__main__':
        main()

发表评论取消回复

表情：

评论列表（有 0 条评论，87人围观）

还没有评论，来说两句吧...

相关阅读

相关 Vue---任意组件间消息订阅与发布（pubsub）

对比全局事件总线学习（不要混） [http://t.csdn.cn/4PYmQ][http_t.csdn.cn_4PYmQ] 目录总结工作模型下载库引入库

阳光穿透心脏的1/2处/ 2024年04月07日 15:36/ 0 赞/ 108 阅读

相关【ZMQ】ZMQ/ZeroMQ简介、三种消息模式demo程序

ZMQ/ZeroMQ简介、三种消息模式demo程序一、什么是ZMQ 二、ZMQ的特点三、Demo程序代码 3.1 发布-订阅模式（P/S

灰太狼/ 2024年02月20日 13:12/ 0 赞/ 82 阅读

相关 zeromq发布订阅模式及监控monitor

> zeromq是一个高性能的消息中间件，对于使用方法及相关的理解在代码注解中讲的很清楚了，直接看代码就好了。 1.zeromq服务端示例代码 package

今天药忘吃喽~/ 2023年10月09日 12:31/ 0 赞/ 37 阅读

相关消息队列——发布订阅模式

在 Redis 中提供了专门的类型：Publisher（发布者）和 Subscriber（订阅者）来实现消息队列。在文章开始之前，先来介绍消息队列中有几个基础概念，以便大家

秒速五厘米/ 2023年10月05日 12:39/ 0 赞/ 92 阅读

相关消息队列点到点模式和发布订阅模式

Table of Contents 概念简述两者区别流行消息队列的消息模型比较 RabbitMQ Kafka Pulsar -----------------

ゞ浴缸里的玫瑰/ 2023年06月11日 10:29/ 0 赞/ 49 阅读

相关 ZeroMQ消息Python版：pyzmq发布响应模式（ Pub-Sub模式）

服务端： import zmq import sys import time def main(): co

不念不忘少年蓝@/ 2022年12月28日 06:11/ 0 赞/ 88 阅读

相关 ZeroMQ消息Python版本：pyzmq请求响应模式（ Request-Reply模式）

ZeroMQ消息：pyzmq请求响应模式（ Request-Reply），Python 服务端： import zmq import sys

拼搏现实的明天。/ 2022年12月28日 05:29/ 0 赞/ 111 阅读

相关 redis：pubsub发布订阅

引入我们知道，redis可以用作消息队列，但是redis消息队列有个不足之处，那就是它不支持消息的多播机制。而redis的发布PubSub 模式可以解决这个问题。 >

本是古典何须时尚/ 2022年09月14日 11:11/ 0 赞/ 216 阅读

相关 RabbitMQ消息分发模式----"Publish/Subscribe"发布/订阅模式

介绍我们都是基于一个队列发送和接受消息。前面讲的几种，不管是生产者端还是消费者端都必须知道一个指定的QueueName才能发送、获取消息。而RabbitMQ消息模

深藏阁楼爱情的钟/ 2022年08月20日 04:18/ 0 赞/ 262 阅读

相关使用发布订阅PubSub

一、PubSub消息传递模式介绍发布-订阅（Publish-Subscribe， PubSub)是一种历史悠久的经典消息传递模式。在发布-订阅模式中，想要发布事件（eve

叁歲伎倆/ 2022年02月26日 14:40/ 0 赞/ 246 阅读