使用python发送接受rocketmq消息~

逆熵元组
• 阅读 12830

如何使用python进行rocketmq的消息接受和推送?(请在ubuntu下操作,rocketmq-python不支持windows!!!)

首先我们使用pycharm进行安装有关rocketmq的包
pip install rocketmq-client-python
pip install rocketmq

然后查看pycharm终端 pip list是否安装
使用python发送接受rocketmq消息~

然后创建py文件进行发送消息编写 (注意调用的包)

如图:
使用python发送接受rocketmq消息~

再创建py文件进行接受消息编写(注意调用的包)

如图:
使用python发送接受rocketmq消息~

编写完成后配合rocketmq的界面管理进行测试

发送:

使用python发送接受rocketmq消息~

接受:

使用python发送接受rocketmq消息~

我们可以在rocketmq管理界面中进行查看

如图:

使用python发送接受rocketmq消息~

这样我们就可以使用python进行简易的接受和发送消息了。后续我们再进行更复杂的消息推送,如:定时,广播,有序...

点赞
收藏
评论区
推荐文章
Stella981 Stella981
3年前
RabbitMQ_消息队列基本使用_2
简介RabbitMQ:接受消息再传递消息,可以视为一个“邮局”。发送者和接受者通过队列来进行交互,队列的大小可以视为无限的,多个发送者可以发生给一个队列,多个接收者也可以从一个队列中接受消息。pika&使用rabbitmq使用的协议是amqp,用于python的推荐客户端是pikapipinstallpika
Stella981 Stella981
3年前
SpringBoot如何优雅的使用RocketMQ
目录SpringBoot如何优雅的使用RocketMQ什么是RocketMQ?RocketMQ环境安装SpringBoot环境中使用RocketMQSpringBoot如何优雅的使用RocketMQMQ,是一种跨进程的通信机制,用于上下游传递消息。在传统的互联网架构中通常使用M
Stella981 Stella981
3年前
Kafka、RabbitMQ、RocketMQ等消息中间件的对比 —— 消息发送性能和区别
Kafka、RabbitMQ、RocketMQ等消息中间件的对比——消息发送性能和区别那么,消息中间件性能究竟哪家强?带着这个疑问,我们中间件测试组对常见的三类消息产品(Kafka、RabbitMQ、RocketMQ)做了
Stella981 Stella981
3年前
RocketMq sendDefaultImpl call timeout异常解决
今天部署完RocketMq,使用客户端进行发送消息发现,异常如下:RemotingTooMuchRequestException:sendDefaultImplcalltimeout这肯定是produce没有连上Rocketmq的broker,按照rocketmq的官网实例进行检查,发现跟例子没啥区别,题外话:这里要吐槽一下阿里相关开源产品的文档
Stella981 Stella981
3年前
RocketMQ 消息发送system busy、broker busy原因分析与解决方案
微信公众号「中间件兴趣圈」主要关注RocketMQ、Dubbo、Netty、Elasticsearch、ElasticJob、Mycat、Mybatis等主流开源中间件。1、现象最近收到很多RocketMQ使用者,反馈生产环境中在消息发送过程中偶尔会出现如下4个错误信息之一:\REJECTREQUEST\systemb
Easter79 Easter79
3年前
SpringBoot如何优雅的使用RocketMQ
目录SpringBoot如何优雅的使用RocketMQ什么是RocketMQ?RocketMQ环境安装SpringBoot环境中使用RocketMQSpringBoot如何优雅的使用RocketMQMQ,是一种跨进程的通信机制,用于上下游传递消息。在传统的互联网架构中通常使用M
Stella981 Stella981
3年前
Linux的centos7.2部署rocketMq3.5.8
背景最近公司的终端机需要接通推送,然后查看对比了一下,觉得rocketMq更合适一点,所以选择了rocketMq进行测试。软件清单a、git(yumintsallgit);b、jdk1.8;c、maven;d、rocketmq操作步骤1、首先下载rocketMq3.5.82、tarzxvfroc
Stella981 Stella981
3年前
RokectMQ 顺序性 和分布式事务
1.顺序性是根据参数的id来使其同时投递到统一队列上。//RocketMQ通过MessageQueueSelector中实现的算法来确定消息发送到哪一个队列上//RocketMQ默认提供了两种MessageQueueSelector实现:随机/Hash//当然你可以根据业务实现自己的MessageQueueSelecto
Stella981 Stella981
3年前
RocketMQ消息轨迹
RocketMQ消息轨迹主要包含两篇文章:设计篇与源码分析篇,本节将详细介绍RocketMQ消息轨迹设计相关。RocketMQ消息轨迹,主要跟踪消息发送、消息消费的轨迹,即详细记录消息各个处理环节的日志,从设计上至少需要解决如下三个核心问题:消费轨迹数据格式记录消息轨迹(消息日志)消息轨迹数据存储在哪?1、消息轨迹数
Stella981 Stella981
3年前
Netty在Dubbo中的线程名称
在项目中,我们会使用RocketMQ和Dubbo.前者用于发送或消费消息,后者用于两个模块之间的接口调用.RocketMQ和Dubbo在它们的底层都使用Netty作为网络通信的框架.那么今天我们就来看一下,在Dubbo中,使用的Netty线程名称叫什么?环境和流程如下1.启动zookeeper2.一个简单的Dubbo提供者,并启动它
美凌格栋栋酱 美凌格栋栋酱
5个月前
Oracle 分组与拼接字符串同时使用
SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(