专栏首页python3python 发送和接收ActiveMQ

python 发送和接收ActiveMQ

ActiveMQ是java开发的消息中间件服务。可以支持多种协议(AMQP,MQTT,OpenWire,Stomp),默认的是OpenWire。而python与ActiveMQ的通信使用的是Stomp协议。而如果你的服务没有开启则需要配置开启。

首先需要安装python的stomp库。命令如下:

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

# 推送到队列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()

##从队列接收消息
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()

但是上述只是发送文本类型的消息,除此之外,ActiveMQ还支持MapMessage、ObjectMessage、BytesMessage、和StreamMessage等多个消息类型。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • python使用sqlite简单介绍

    以下是基本用法,创建test.db文件,添加一张dept表,添加4条数据,再删除一条,最后读取数据

    py3study
  • python MySQLdb 常用操作

    请注意一定要有conn.commit()这句来提交事务,要不然不能真正的插入数据。

    py3study
  • 每天一个python小程序

    做为 Apple Store App 独立开发者,你要搞限时促销,为你的应用生成200个激活码(或者优惠券),并将生成的激活码(或者优惠券)保存到 MySQL ...

    py3study
  • HTTPURLConnection 发送Post数据

    http://blog.csdn.net/chenlei1889/article/details/6363356

    2Simple
  • python对mysql数据库操作之代码优化(二)

    conn=MySQLdb.connect(host='localhost',user='root',

    无涯WuYa
  • Scalaz(37)- Free :实践-DB Transaction free style

      我一直在不断的提示大家:FP就是Monadic Programming,是一种特殊的编程风格。在我们熟悉的数据库编程领域能不能实现FP风格呢?我们先设计一些...

    用户1150956
  • jdbc

    jdbc.driver=com.mysql.jdbc.Driver jdbc.url=jdbc:mysql://localhost:3306/dangdang ...

    Dean0731
  • JDBC使用流程和封装类

    万能青年
  • 第三十天-加强2-多表查询&JDBC&连接池&DBUtils&综合案例【悟空教程】

    第三十天-加强2-多表查询&JDBC&连接池&DBUtils&综合案例【悟空教程】

    奋斗蒙
  • Python接入mysql数据库 原

    右侧有个database,点开后左上角有个“+”符号,选择Data Source-Mysql

    晓歌

扫码关注云+社区

领取腾讯云代金券