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

不念不忘少年蓝@ 2022-12-28 06:11 63阅读 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 条评论，63人围观）

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

相关阅读

相关详解Python 实现 ZeroMQ 的三种基本工作模式

更多编程教程请到：[菜鸟教程][Link 1] https://www.piaodoo.com/ 友情链接： [高州阳光论坛][Link 2]https://www.hnt

阳光穿透心脏的1/2处/ 2023年01月03日 11:28/ 0 赞/ 138 阅读

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

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

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

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

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

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

相关 redis：pubsub发布订阅

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

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

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

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

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

相关 python版：装饰器模式

装饰器模式介绍装饰模式指的是在不必改变原类文件和使用继承的情况下，动态地扩展一个对象的功能。它是通过创建一个包装对象，也就是装饰来包裹真实的对象。

深碍√TFBOYSˉ_/ 2022年06月01日 03:08/ 0 赞/ 172 阅读

相关抽象工厂模式(python版)

http://blog.csdn.net/ponder008/article/details/6886039 抽象工厂模式：提供一个创建一系列相关或相互依赖对象的接口，而无需

男娘i/ 2022年03月29日 08:16/ 0 赞/ 92 阅读

相关使用发布订阅PubSub

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

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

相关 Redis队列（二）：消息的发布与订阅PubSub的使用

一、概述消息发布订阅模式在之前的文章中介绍了使用Redis列表这种数据类型来实现一个轻量级的消息队列，不过使用列表实现的消息队列存在一个缺陷就是由于是基于

迷南。/ 2022年01月21日 07:25/ 0 赞/ 443 阅读

相关消息队列模式（点对点&发布订阅）

\\背景知识 JMS一个在 Java标准化组织（JCP）内开发的标准（代号JSR 914）。2001年6月25日，Java消息服务发布JMS 1.0.2b，2002年3月1

妖狐艹你老母/ 2022年01月17日 10:07/ 0 赞/ 331 阅读