python 發(fā)送和接收ActiveMQ消息的實(shí)例
ActiveMQ是java開(kāi)發(fā)的消息中間件服務(wù)??梢灾С侄喾N協(xié)議(AMQP,MQTT,OpenWire,Stomp),默認(rèn)的是OpenWire。而python與ActiveMQ的通信使用的是Stomp協(xié)議。而如果你的服務(wù)沒(méi)有開(kāi)啟則需要配置開(kāi)啟。
首先需要安裝python的stomp庫(kù)。
命令如下:
pip install stomp.py
接著,就是上代碼了具體如下:
# -*-coding:utf-8-*- import stomp import time queue_name = '/queue/SampleQueue' topic_name = '/topic/SampleTopic' listener_name = 'SampleListener' class SampleListener(object): def on_message(self, headers, message): print 'headers: %s' % headers print 'message: %s' % message # 推送到隊(duì)列queue def send_to_queue(msg): conn = stomp.Connection10([('127.0.0.1',61613)]) conn.start() conn.connect() conn.send(queue_name, msg) conn.disconnect() #推送到主題 def send_to_topic(msg): conn = stomp.Connection10([('127.0.0.1',61613)]) conn.start() conn.connect() conn.send(topic_name, msg) conn.disconnect() ##從隊(duì)列接收消息 def receive_from_queue(): conn = stomp.Connection10([('127.0.0.1',61613)]) conn.set_listener(listener_name, SampleListener()) conn.start() conn.connect() conn.subscribe(queue_name) time.sleep(1) # secs conn.disconnect() ##從主題接收消息 def receive_from_topic(): conn = stomp.Connection10([('127.0.0.1',61613)]) conn.set_listener(listener_name, SampleListener()) conn.start() conn.connect() conn.subscribe(topic_name) while 1: send_to_topic('topic') time.sleep(3) # secs conn.disconnect() if __name__=='__main__': # send_to_queue('len 123') # receive_from_queue() receive_from_topic()
但是上述只是發(fā)送文本類型的消息,除此之外,ActiveMQ還支持MapMessage、ObjectMessage、BytesMessage、和StreamMessage等多個(gè)消息類型。
以上這篇python 發(fā)送和接收ActiveMQ消息的實(shí)例就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
- Python如何實(shí)現(xiàn)大型數(shù)組運(yùn)算(使用NumPy)
- python3通過(guò)udp實(shí)現(xiàn)組播數(shù)據(jù)的發(fā)送和接收操作
- Python udp網(wǎng)絡(luò)程序?qū)崿F(xiàn)發(fā)送、接收數(shù)據(jù)功能示例
- Python 網(wǎng)絡(luò)編程之UDP發(fā)送接收數(shù)據(jù)功能示例【基于socket套接字】
- python UDP(udp)協(xié)議發(fā)送和接收的實(shí)例
- Python微信企業(yè)號(hào)開(kāi)發(fā)之回調(diào)模式接收微信端客戶端發(fā)送消息及被動(dòng)返回消息示例
- python通過(guò)get,post方式發(fā)送http請(qǐng)求和接收http響應(yīng)的方法
- Python中使用socket發(fā)送HTTP請(qǐng)求數(shù)據(jù)接收不完整問(wèn)題解決方法
- python發(fā)送郵件接收郵件示例分享
- Python如何發(fā)送與接收大型數(shù)組
相關(guān)文章
Python的反射函數(shù)與內(nèi)省工具深入解析
這篇文章主要為大家介紹了Python的反射函數(shù)與內(nèi)省工具深入解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-06-06Pandas實(shí)現(xiàn)一列數(shù)據(jù)分隔為兩列
這篇文章主要介紹了Pandas實(shí)現(xiàn)一列數(shù)據(jù)分隔為兩列,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-05-05python中threading和queue庫(kù)實(shí)現(xiàn)多線程編程
這篇文章主要介紹了python中threading和queue庫(kù)實(shí)現(xiàn)多線程編程,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-02-02python中實(shí)現(xiàn)k-means聚類算法詳解
這篇文章主要介紹了python中實(shí)現(xiàn)k-means聚類算法詳解,具有一定參考價(jià)值,需要的朋友可以了解下。2017-11-11python中py文件與pyc文件相互轉(zhuǎn)換的方法實(shí)例
pyc是一種二進(jìn)制文件,是由py文件經(jīng)過(guò)編譯后,生成的文件,下面這篇文章主要給大家介紹了關(guān)于python中py文件與pyc文件相互轉(zhuǎn)換的相關(guān)資料,需要的朋友可以參考下2022-05-05Python Web編程之WSGI協(xié)議簡(jiǎn)介
這篇文章主要介紹了Python Web編程之WSGI協(xié)議,簡(jiǎn)單說(shuō)明了WSGI的概念、功能并結(jié)合實(shí)例形式分析了Gunicorn和uWSGI相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下2018-07-07Python/R語(yǔ)言分別實(shí)現(xiàn)斐波那契數(shù)列的示例詳解
這篇文章將通過(guò)兩個(gè)小問(wèn)題:年齡計(jì)算、斐波那契數(shù)列,帶領(lǐng)大家深入淺出的理解兩種語(yǔ)言的基本語(yǔ)法,并用以實(shí)際場(chǎng)景,需要的可以參考一下2022-03-03