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

时间：2022-04-02 10:03:16类别：脚本大全

从零开始学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

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

从零开始学activemq

猜您喜欢

热门推荐