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.pswp.cn/web/80147.shtml
繁體地址,請注明出處:http://hk.pswp.cn/web/80147.shtml
英文地址,請注明出處:http://en.pswp.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;通過…