当前位置: 首页 > news >正文

rocketmq 环境配置[python]

因本人是 python 开发,macbook 开发。windows 可以采取配置远程 linux 解释器或者 pycharm 专业版的 docker 解释器进行开发

M1 芯片 本地运行 rocketmq

rocketmq Python 开源地址:

https://github.com/apache/rocketmq-client-python

因为需要 linux c/c++ libs包,官方只给出了centos ,debain,macOS 配置信息

终端使用 brew install wget 命令 【注意代理/或开启 tun 模式】

x86_64 架构的 librocketmq.dylib

wget <https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz>
tar -xzf rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz
cd rocketmq-client-cpp
sudo mkdir /usr/local/include/rocketmq
sudo mkdir -p /usr/local/lib
sudo cp include/* /usr/local/include/rocketmq
sudo cp lib/* /usr/local/lib>>>>>修正动态库 ID(macOS 的 install_name_tool) 
>>>>>这一步是为了确保 Python 在加载 .dylib 时不出错(macOS 默认路径检查严格)sudo install_name_tool -id "@rpath/librocketmq.dylib" /usr/local/lib/librocketmq.dylib

上面会把 librocketmq.dylib 安装到 /usr/local/lib/,让动态链接器可以找到它

为了避免后续找不到 .dylib

  1. 确保文件放到了 /usr/local/lib/librocketmq.dylib [✅ 添加链接路径到系统环境变量]

vim ~/.zshrc

echo 'export DYLD_LIBRARY_PATH="/usr/local/lib:$DYLD_LIBRARY_PATH"' >> ~/.zshrc
source ~/.zshrc

验证:

ls /usr/local/lib/librocketmq.dylib

由于 mac 都是 m1芯片的,Intel x86 的可以忽略该操作。

否则使用 arm 架构的有这个错误!!!!

OSError: ... is an incompatible architecture (have 'x86_64', need 'arm64e' or 'arm64')
  1. 使用 Rosetta 启动终端(右键 iTerm → “使用 Rosetta 打开”)【显示简介】

https://cdn.jsdelivr.net/gh/jacinli/image-hosting@main/notes/202505161413677.png

点击显示简介

x86_64 的 conda 环境:

CONDA_SUBDIR=osx-64 conda create -n rocketmq-x86 python=3.10
conda activate rocketmq-x86>>>>>>>
python -c "import platform; print(platform.machine())" 
>>>>>
x86_64

安装依赖:

pip install rocketmq-client-python

验证操作:

python -c "import platform; print(platform.machine())"验证成功:
from rocketmq.client import Producer
print("RocketMQ 启动成功 ✅")

上面就表示已经成功导入。

如果是本地运行,请使用腾讯云 mq 公网地址

【无法使用 arm 架构的 librocketmq.dylib 】

这个前提是:官方有提供 ARM 架构的 RocketMQ C++ SDK,但很遗憾:

🔥 截止目前(2025),Apache 官方只提供了

x86_64 的 Darwin 版本

⚠️ 没有 ARM64 架构的 .dylib,所以你

无法直接在 M1 的原生 Python 上运行

腾讯云rocketmq 配置

因为这个和其他的不太一样

项目腾讯云 RocketMQ
NameServer 地址是腾讯云提供的专属地址,例如 rmq-cn-xxx.rmq.cloud.tencent.com:8080
Topic必须先在 腾讯云控制台创建 Topic
Group、权限等都要在控制台配置或授权
自动创建 Topic❌ 不支持(和 Apache 的 autoCreateTopic=true 不一样)

在控制台 先创建 topic :创建名为 dev-test-mq-for-0516 的 Topic

然后发送测试消息 【这样保证域名能被解析到】

rocketmq.exceptions.ProducerSendSyncFailed: No route info of this topic: dev-test-mq-for-0516

如果有这个错误 可以看一下 自己的集群 地址,看看本地开发到底是公网还是私网地址,这个很重要!!!!

可以创建一个 group 来测试。

在腾讯云操作上必须要创建 topic group 现有这两个,才可以进行消费与生产!!!!!

❗这是最关键的一步!否则客户端永远查不到路由。

请这样操作:

  1. 打开控制台 ➝ RocketMQ 实例 ➝ Topic 管理 ➝ 点进 dev-test-mq-for-0516
  2. 查看 队列数量 是不是 0?(你之前看到是 3,但如果不是绑定在你当前集群的 Broker 上,也等于没用)
  3. 点右侧「编辑
  4. 重新设置队列数量为 3(或其他),然后点保存提交

这样就会重新绑定路由到 Broker。

回到 Topic 管理 ➝ 点 发送测试消息,填点消息内容,发送一下。

这个过程就会刷新 NameServer 的路由缓存。

可以测一测网络信息,以免是网络


telnet rmq-xxxx.rocketmq.gz.qcloud.tencenttdmq.com 8080ping rmq-xxxx.rocketmq.gz.qcloud.tencenttdmq.com 

腾讯云的 RocketMQ 默认是 VPC 专网访问,如果你本地是公网,要配置公网访问地址,并且:

  • 对应账号要开启公网访问权限
  • SDK 需要用公网域名
  • AK/SK 权限配置正确

相关文章:

  • 7-15 计算圆周率
  • 增量学习:机器学习领域中的资源高效利用秘籍
  • 大语言模型 09 - 从0开始训练GPT 0.25B参数量 补充知识之数据集 Pretrain SFT RLHF
  • C++23 中的 ranges::fold_left:范围折叠算法
  • C语言进阶-数组和函数
  • 深入解析Spring Boot与微服务架构:从入门到实践
  • 智能呼叫系统中的NLP意图理解:核心技术解析与实战
  • Android 中 打开文件选择器(ACTION_OPEN_DOCUMENT )
  • 基于React的高德地图api教程005:圆形标记的绘制、删除、修改
  • 0-INViT:一个具有不变嵌套视图Transformer的可推广路由问题求解器(code)(未完)
  • GDB 高级调试技术深度解析
  • 【Python+flask+mysql】网易云数据可视化分析(全网首发)
  • STM32F103经SPI总线向写Micro SD卡
  • 怎么使用python进行PostgreSQL 数据库连接?
  • Web性能优化的未来:边缘计算、AI与新型渲染架构
  • WebMvcConfigurer介绍-笔记
  • 算法刷题(Java与Python)1.二分查找
  • 车道线检测----CLRERNet
  • 【云实验】基于对象存储OSS实现企业门户网站托管
  • RNope:结合 RoPE 和 NoPE 的长文本建模架构
  • 全国多家健身房女性月卡延长,补足因月经期耽误的健身时间
  • 新华时评:博物馆正以可亲可近替代“高冷范儿”
  • 娃哈哈:调整产销布局致部分工厂停工,布局新产线可实现自主生产,不排除推新品牌
  • 现场丨在胡适施蛰存等手札与文献间,再看百年光华
  • 诠释微末处的丰盈:“上海制造佳品汇”首届海外专场即将亮相日本大阪
  • 4月企业新发放贷款利率处于历史低位