【Python】使用python发送接受rocketmq消息~

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

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

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

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

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

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

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

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

发送:

【Python】使用python发送接受rocketmq消息~

接受:

【Python】使用python发送接受rocketmq消息~

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

如图:

【Python】使用python发送接受rocketmq消息~

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

以上是 【Python】使用python发送接受rocketmq消息~ 的全部内容, 来源链接: utcz.com/a/72167.html

回到顶部