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 权限配置正确

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/80147.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

OCCT知识笔记之OCAF框架详解

OCAF框架在OCCT项目中的构建与使用指南 Open CASCADE Application Framework (OCAF)是Open CASCADE Technology (OCCT)中用于管理CAD数据的核心框架&#xff0c;它提供了一种结构化方式来组织和管理复杂的CAD数据&#xff0c;如装配体、形状、属性(颜色、材料)和元数据等。本文…

go-数据库基本操作

1. 配置数据库 package mainimport ("gorm.io/driver/mysql""gorm.io/gorm" ) #配置表结构 type User struct {ID int64 json:"id" gorm:"primary_key" // 主键ID自增长Username stringPassword string } #配置连接接信息 func…

【含文档+PPT+源码】基于大数据的交通流量预测系统

技术栈说明 技术栈&#xff1a; 后端&#xff1a;Django&#xff08;后端是前后端分离的&#xff09; 前端&#xff1a;Vue.js ElementUI 开发工具&#xff1a; Python3.9以上 Pycharm MySQL5.7/MySQL8 VSCode 项目演示视频 基于大数据的交通流量预测系统

海盗王3.0的数据库3合1并库处理方案

原版的海盗王数据库有3个accountserver&#xff0c;gamedb&#xff0c;tradedb&#xff0c;对应到是账号数据库&#xff0c;游戏数据库&#xff0c;商城数据库。 一直都有个想法&#xff0c;如何把这3个库合并到一起&#xff0c;这样可以实现一些功能。 涉及到sqlserver的数据库…

Apollo Client 1.6.0 + @RefreshScope + @Value 刷新问题解析

问题描述 在使用 Apollo Client 1.6.0 结合 Spring Cloud 的 RefreshScope 和 Value 注解时&#xff0c;遇到以下问题&#xff1a; 项目启动时第一次属性注入成功后续配置变更时&#xff0c;Value 属性会刷新&#xff0c;但总是刷新为第一次的旧值&#xff0c;而不是最新的配…

LearnOpenGL --- 你好三角形

你好&#xff0c;三角形的课后练习题 文章目录 你好&#xff0c;三角形的课后练习题一、创建相同的两个三角形&#xff0c;但对它们的数据使用不同的VAO和VBO 一、创建相同的两个三角形&#xff0c;但对它们的数据使用不同的VAO和VBO #include <glad/glad.h> #include &…

STM32F407VET6实战:CRC校验

CRC校验在数据传输快&#xff0c;且量大的时候使用。下面是STM32F407VET6HAL库使用CRC校验的思路。 步骤实现&#xff1a; CubeMX配置 c // 在CubeMX中启用CRC模块 // AHB总线时钟自动启用 HAL库代码 c // 初始化&#xff08;main函数中&#xff09; CRC_HandleTypeDef …

Vue3中实现轮播图

目录 1. 轮播图介绍 2. 实现轮播图 2.1 准备工作 1、准备至少三张图片&#xff0c;并将图片文件名改为数字123 2、搭好HTML的标签 3、写好按钮和图片标签 ​编辑 2.2 单向绑定图片 2.3 在按钮里使用方法 2.4 运行代码 3. 完整代码 1. 轮播图介绍 首先&#xff0c;什么是…

Linux远程连接服务

远程连接服务器简介 远程连接服务器通过文字或图形接口方式来远程登录系统&#xff0c;让你在远程终端前登录linux主机以取得可操作主机接口&#xff08;shell&#xff09;&#xff0c;而登录后的操作感觉就像是坐在系统前面一样。 远程连接服务器的功能 分享主机的运算能力 远…

MySQL面试知识点详解

一、MySQL基础架构 1. MySQL逻辑架构 MySQL采用分层架构设计&#xff0c;主要分为&#xff1a; 连接层&#xff1a;处理客户端连接、授权认证等 服务层&#xff1a;包含查询解析、分析、优化、缓存等 引擎层&#xff1a;负责数据存储和提取&#xff08;InnoDB、MyISAM等&am…

牛客网NC22000:数字反转之-三位数

牛客网NC22000:数字反转之-三位数 &#x1f50d; 题目描述 时间限制&#xff1a;C/C/Rust/Pascal 1秒&#xff0c;其他语言2秒 空间限制&#xff1a;C/C/Rust/Pascal 32M&#xff0c;其他语言64M &#x1f4dd; 输入输出说明 输入描述: 输入一个3位整数n (100 ≤ n ≤ 999)…

C++跨平台开发:突破不同平台的技术密码

Windows 平台开发经验 开发环境搭建 在 Windows 平台进行 C 开发&#xff0c;最常用的集成开发环境&#xff08;IDE&#xff09;是 Visual Studio。你可以从Visual Studio 官网下载安装包&#xff0c;根据安装向导进行安装。安装时&#xff0c;在 “工作负载” 界面中&#xff…

[250516] OpenAI 升级 ChatGPT:GPT-4.1 及 Mini 版上线!

目录 ChatGPT 迎来重要更新&#xff1a;GPT-4.1 和 GPT-4.1 mini 正式上线用户如何访问新模型&#xff1f;技术亮点与用户体验优化 ChatGPT 迎来重要更新&#xff1a;GPT-4.1 和 GPT-4.1 mini 正式上线 OpenAI 宣布在 ChatGPT 平台正式推出其最新的 AI 模型 GPT-4.1 和 GPT-4.…

计算机指令分类和具体的表示的方式

1.关于计算机的指令系统 下面的这个就是我们的一个简单的计算机里面涉及到的指令&#xff1a; m就是我们的存储器里面的地址&#xff0c;可以理解为memory这个意思&#xff0c;r可以理解为rom这样的单词的首字母&#xff0c;帮助我们去进行这个相关的指令的记忆&#xff0c;不…

前端脚手架开发指南:提高开发效率的核心操作

前端脚手架通过自动化的方式可以提高开发效率并减少重复工作&#xff0c;而最强大的脚手架并不是现成的那些工具而是属于你自己团队量身定制的脚手架&#xff01;本篇文章将带你了解脚手架开发的基本技巧&#xff0c;帮助你掌握如何构建适合自己需求的工具&#xff0c;并带着你…

SpringBoot常用注解详解

文章目录 1. 前言2. 核心注解2.1 SpringBootApplication2.2 Configuration2.3 EnableAutoConfiguration2.4 ComponentScan2.5 Bean2.6 Autowired2.7 Qualifier2.8 Primary2.9 Value2.10 PropertySource2.11 ConfigurationProperties2.12 Profile 3. Web开发相关注解3.1 Control…

项目管理进阶:全文解读企业IT系统全生命周期管理与运营平台建设方案【附全文阅读】

本文介绍了《企业IT系统全生命周期管理与运营平台建设方案》的项目内容&#xff0c;包括项目背景、蓝图架构、核心业务流程、系统总体架构、解决方案等。 重点内容&#xff1a; 1. 项目背景&#xff1a;介绍企业IT系统全生命周期管理的重要性。 2. 蓝图架构&#xff1a;描述项目…

记录一次vue项目页面内嵌iframe页面实现跨域上传和下载附件的功能

功能背景&#xff1a;项目部署在外网&#xff0c;然后其中有一个功能需要上传下载附件&#xff0c;附件是上传到华为云对象存储服务OBS中&#xff08;私有云&#xff09;&#xff0c;所以采用iframe嵌套页面的方式解决跨域问题。 实现思路&#xff1a; 1、父窗口封装一个组件专…

rust语言,与c,go语言一样也是编译成二进制文件吗?

是的&#xff0c;Rust 和 C、Go 一样&#xff0c;默认情况下会将代码编译成二进制可执行文件&#xff08;如 ELF、PE、Mach-O 等格式&#xff09;&#xff0c;但它们的编译过程和运行时特性有所不同&#xff1a; 1. Rust&#xff08;类似 C&#xff0c;直接编译为机器码&#x…

后端框架(3):Spring(2)

AOP 概述&#xff1a;AspectOrientedProgramming 面向切面编程&#xff1a;是对面向对象编程的补充延续&#xff0c;面向切面编程思想是将程序中非业务代码(提交事务&#xff0c;打印日志&#xff0c;权限验证&#xff0c;统一异常处理) 然后在调用业务代码时&#xff0c;通过…