您的位置:首页 > 脚本大全 > > 正文

从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

更多 时间:2022-04-02 10:03:16 类别:脚本大全 浏览量:2459

从零开始学activemq

ActiveMQ:使用Python访问ActiveMQ的方法

windows 10家庭中文版,python 3.6.4,stomp.py 4.1.21

activemq支持python访问,提供了基于stomp协议(端口为61613)的库。

activemq的官文cross language clients中给出了更详细的介绍,并附有示例代码,如下图:

第一行为常规python访问,第二行为使用jython访问的方式,四个操作。

从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

python访问activemq需要使用stomp.py,见其官网。。

下载官网的代码,解压,命令行进入其目录,使用pyhthon setup.py install即可安装好,然后就可以使用stomp.py了。

官方示例代码:给队列test发送一个消息,也可以把第7行的destination的“/queue/”去掉,只剩test。

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • import stomp
  •  
  • conn = stomp.connection()
  • conn.set_listener('', mylistener())
  • conn.start()
  • conn.connect('admin', 'password', wait=true)
  • conn.send(body=' '.join(sys.argv[1:]), destination='/queue/test')
  • conn.disconnect()
  • 测试结果:test队列接收到消息数量增加了

    从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

    stomp.connection()默认是connect.stompconnection11(协议1.1),还可以可以选择1.0、1.2。

    从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

    在官方代码中,stomp.connection()的参数为空,实际上可以有很多参数,比如,设置broker的ip地址和端口,如下:其中的host_and_ports就是设置ip和端口的。

    从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

    ip和端口设置示例:

    c = stomp.connection([('127.0.0.1', 62613)])

    这里我犯错了,端口我协程了8161(activemq的web访问的端口),经查询(百度搜索到stackoverflow.com)才知,stomp协议用的是61613(activemq的配置文件中):

    从零开始学activemq(ActiveMQ:使用Python访问ActiveMQ的方法)

    activemq官网的四个测试:

    发送消息到队列queue属于 点对点模式,不可以重复消费;

    发送消息到主题topic属于 发布/订阅模式,可以重复消费;

  • ?
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • # send a message to an apache activemq queue
  • import stomp
  •  
  • conn = stomp.connection10()
  •  
  • conn.start()
  •  
  • conn.connect()
  •  
  • conn.send('samplequeue', 'simples assim')
  •  
  • conn.disconnect()
  •  
  • # receive a message from an apache activemq queue
  • import stomp
  • import time
  •  
  • class samplelistener(object):
  •  def on_message(self, headers, msg):
  •  print(msg)
  •  
  • conn = stomp.connection10()
  •  
  • conn.set_listener('samplelistener', samplelistener())
  •  
  • conn.start()
  •  
  • conn.connect()
  •  
  • conn.subscribe('samplequeue')
  •  
  • time.sleep(1) # secs
  •  
  • conn.disconnect()
  •  
  • # send a message to an apache activemq topic
  • import stomp
  •  
  • conn = stomp.connection10()
  •  
  • conn.start()
  •  
  • conn.connect()
  •  
  • conn.send('/topic/sampletopic', 'simples assim')
  •  
  • conn.disconnect()
  •  
  • # receive a message from an apache activemq topic (1)
  • import stomp
  • import time
  •  
  • class samplelistener(object):
  •  def on_message(self, headers, msg):
  •  print(msg)
  •  
  • conn = stomp.connection10()
  •  
  • conn.set_listener('samplelistener', samplelistener())
  •  
  • conn.start()
  •  
  • conn.connect()
  •  
  • conn.subscribe('/topic/sampletopic')
  •  
  • time.sleep(1) # secs
  •  
  • conn.disconnect()
  •  
  • # receive a message from an apache activemq topic (2)
  • import stomp
  • import time
  •  
  • class samplelistener(object):
  •  def on_message(self, headers, msg):
  •  print(msg)
  •  
  • conn = stomp.connection10()
  •  
  • conn.set_listener('samplelistener', samplelistener())
  •  
  • conn.start()
  •  
  • conn.connect(headers={'client-id':'sampleclient'})
  •  
  • conn.subscribe(destination='/topic/sampletopic', headers={'activemq.subscriptionname':'samplesubscription'})
  •  
  • time.sleep(1) # secs
  •  
  • conn.disconnect()
  • 以上这篇activemq:使用python访问activemq的方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持开心学习网。

    原文链接:https://www.cnblogs.com/luo630/p/9188107.html

    标签:Python ActiveMQ
    您可能感兴趣