rocketmq-python 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
rocketmq-python 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
授权协议 MIT
开发语言 Python
操作系统 跨平台
软件类型 开源软件
开发厂商
地区 国产
提 交 者 messense
适用人群 未知
收录时间 2019-06-02

软件简介

rocketmq-python 是一个基于 rocketmq-client-cpp 封装的 RocketMQ Python 客户端。

示例代码:

Producer

from rocketmq.client import Producer, Message

producer = Producer('PID-XXX')
producer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')
# For ip and port name server address, use `set_namesrv_addr` method, for example:
# producer.set_namesrv_addr('127.0.0.1:9887')
producer.set_session_credentials('XXX', 'XXXX', 'ALIYUN')
producer.start()

msg = Message('YOUR-TOPIC')
msg.set_keys('XXX')
msg.set_tags('XXX')
msg.set_body('XXXX')
ret = producer.send_sync(msg)
print(ret.status, ret.msg_id, ret.offset)
producer.shutdown()

PushConsumer

import time

from rocketmq.client import PushConsumer


def callback(msg):
    print(msg.id, msg.body)


consumer = PushConsumer('CID_XXX')
consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')
# For ip and port name server address, use `set_namesrv_addr` method, for example:
# consumer.set_namesrv_addr('127.0.0.1:9887')
consumer.set_session_credentials('XXX', 'XXXX', 'ALIYUN')
consumer.subscribe('YOUR-TOPIC', callback)
consumer.start()

while True:
    time.sleep(3600)

consumer.shutdown()

PullConsumer

from rocketmq.client import PullConsumer


consumer = PullConsumer('CID_XXX')
consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')
# For ip and port name server address, use `set_namesrv_addr` method, for example:
# consumer.set_namesrv_addr('127.0.0.1:9887')
consumer.set_session_credentials('XXX', 'XXXX', 'ALIYUN')
consumer.start()

for msg in consumer.pull('YOUR-TOPIC'):
    print(msg.id, msg.body)

consumer.shutdown()
展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (0)

加载中
更多评论
暂无内容
发表于服务端专区
04/26 22:30

RocketMQ-mac安装rocketmq

1.官网下载rocketmq指定版本的二进制压缩文件,然后解压 2.配置mq环境变量到.bash_profile export ROCKETMQ_HOME=/Users/dengpingxu/software/rocketmq-all-4.7.0-bin-release export PATH=$PATH:$ROCKETMQ_HOME......

0
0
发表于AI & 大数据专区
04/26 22:38

RocketMQ-rocketmq事务原理

一个简单的基于rocketmq事务消息实现的分布式事务 消息生产者代码-发送事务消息 public class Producer { private static TransactionMQProducer producer = null; private static ExecutorService......

0
1
发表了博客
2019/01/18 10:05

阿里rocketmq与自建rocketmq

一、搭环境 阿里rocketmq不用搭建, https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.6.546.1787650eShM7ho 开源rocketmq(window+rocketmq) https://www.cnblogs.com/amuge/articles/10275292.html 二、发送消息类型: 三、名词解释 https://help.aliyun.com/document_detail/29533.html?spm=a...

0
0
2019/04/11 21:22

rocketMq

公司是做零售领域的。现在在做追溯系统,需要对外提供接口和对内提供接口。一些东西是通过触发器来触发的。然后调用接口。这样的方式问题在于,有可能系统会启动,导致数据的丢失情况。面对这种问题,一种方式在建...

0
0
发表了博客
2018/06/06 19:52

RocketMQ

一.RocketMQ安装 用git把代码拉取到本地, https://github.com/apache/rocketmq.git 使用maven打包工程,mvn clean install -D skipTests -P release-all -U 二.启动RocketMQ 进入distribution\target\apache-rocketmq\bin目录。 先启动nameserver 服务,以管理员权限运行mqnamesrv.cmd, 然后执行broker服务,在dos窗口输...

0
0
发表了博客
2018/08/01 16:18

RocketMQ

应用场景 主要作用解耦、滑峰填谷 异构系统的整合,这个问题比较容易理解,在原阿里SOA ESB比较火的年代,很多异构系统需要进行互联互通。 应用和应用之间的松耦合,这个在阿里巴巴内部很多的同步链路到异步链路里面,使用的非常多。 事件驱动机制和复杂事件架构模型里面的Backbone,底层的机制可以通过MQ来玩转。 数据复...

0
0
发表于服务端专区
2018/03/08 11:25

rocketmq

F:\rocketmq.txt 新建一个文件,内容如下: listenPort=80 启动命令行中新增 -c F:\\rocketmq.txt,即可。 在windows 下,启动broker失败。 报错是 找不到或无法加载主类 Files 修改如下: runbroker.cmd 中,将 ```cmd set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%" 改为 set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%"" ``...

0
0
发表于服务端专区
2019/12/18 22:36

RocketMQ

底层通过Netty实现; Broker写文件的方式存储消息,消息内容先写到内存中,然后异步刷到磁盘,算盘方式有三种; 异步+内存缓冲池:先写入内存字节缓冲区(writeBuffer) ----> 从内存字节缓冲区(write buffer)提交(...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
暂无内容
0 评论
4 收藏
分享
返回顶部
顶部