欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

python 發(fā)送和接收ActiveMQ消息的實(shí)例

 更新時(shí)間:2019年01月30日 09:54:37   作者:像風(fēng)一樣的自由  
今天小編就為大家分享一篇python 發(fā)送和接收ActiveMQ消息的實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

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è)參考,也希望大家多多支持腳本之家。

相關(guān)文章

  • Python的反射函數(shù)與內(nèi)省工具深入解析

    Python的反射函數(shù)與內(nèi)省工具深入解析

    這篇文章主要為大家介紹了Python的反射函數(shù)與內(nèi)省工具深入解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-06-06
  • python3 配置logging日志類的操作

    python3 配置logging日志類的操作

    這篇文章主要介紹了python3 配置logging日志類的操作方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-04-04
  • Pandas實(shí)現(xiàn)一列數(shù)據(jù)分隔為兩列

    Pandas實(shí)現(xiàn)一列數(shù)據(jù)分隔為兩列

    這篇文章主要介紹了Pandas實(shí)現(xiàn)一列數(shù)據(jù)分隔為兩列,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-05-05
  • pycharm如何中導(dǎo)入本地下載好的庫(kù)

    pycharm如何中導(dǎo)入本地下載好的庫(kù)

    這篇文章主要介紹了pycharm如何中導(dǎo)入本地下載好的庫(kù)問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2024-08-08
  • python中threading和queue庫(kù)實(shí)現(xiàn)多線程編程

    python中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-02
  • python中實(shí)現(xiàn)k-means聚類算法詳解

    python中實(shí)現(xiàn)k-means聚類算法詳解

    這篇文章主要介紹了python中實(shí)現(xiàn)k-means聚類算法詳解,具有一定參考價(jià)值,需要的朋友可以了解下。
    2017-11-11
  • python中py文件與pyc文件相互轉(zhuǎn)換的方法實(shí)例

    python中py文件與pyc文件相互轉(zhuǎn)換的方法實(shí)例

    pyc是一種二進(jìn)制文件,是由py文件經(jīng)過(guò)編譯后,生成的文件,下面這篇文章主要給大家介紹了關(guān)于python中py文件與pyc文件相互轉(zhuǎn)換的相關(guān)資料,需要的朋友可以參考下
    2022-05-05
  • Python Web編程之WSGI協(xié)議簡(jiǎn)介

    Python Web編程之WSGI協(xié)議簡(jiǎn)介

    這篇文章主要介紹了Python Web編程之WSGI協(xié)議,簡(jiǎn)單說(shuō)明了WSGI的概念、功能并結(jié)合實(shí)例形式分析了Gunicorn和uWSGI相關(guān)實(shí)現(xiàn)技巧,需要的朋友可以參考下
    2018-07-07
  • Python/R語(yǔ)言分別實(shí)現(xiàn)斐波那契數(shù)列的示例詳解

    Python/R語(yǔ)言分別實(shí)現(xiàn)斐波那契數(shù)列的示例詳解

    這篇文章將通過(guò)兩個(gè)小問(wèn)題:年齡計(jì)算、斐波那契數(shù)列,帶領(lǐng)大家深入淺出的理解兩種語(yǔ)言的基本語(yǔ)法,并用以實(shí)際場(chǎng)景,需要的可以參考一下
    2022-03-03
  • Pytorch中.new()的作用詳解

    Pytorch中.new()的作用詳解

    今天小編就為大家分享一篇Pytorch中.new()的作用詳解,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-02-02

最新評(píng)論