python stomp activemq客户端

#coding=utf-8import timeimport sysimport stomp

class MyListener(object):    def on_error(self, headers, message):        print(‘received an error %s‘ % message)

def on_message(self, headers, message):        print(‘received a message %s‘ % message)        time.sleep(2)

conn = stomp.Connection([(‘192.168.251.191‘,61613)])conn.set_listener(‘‘, MyListener())conn.start()conn.connect()
# 注意,官方示例这样发送消息的  $ python simple.py hello world#conn.send(body=‘hello,garfield! this is ‘.join(sys.argv[1:]), destination=‘/queue/test‘)

#发送消息到队列 conn.send(body=‘this is message‘), destination=‘/queue/test‘)
#发送消息到主题 conn.send(body=‘this is message‘), destination=‘/topic/testTopic‘)
 
#从队列接受消息conn.subscribe(destination=‘/queue/test‘, id=1, ack=‘auto‘)
#从主题接受消息conn.subscribe(destination=‘/topic/testTopic‘, id=1, ack=‘auto‘)
time.sleep(2)conn.disconnect()
时间: 2024-10-18 23:00:54

python stomp activemq客户端的相关文章

python+stomp+activemq

python也可以连接MQ,以ActiveMQ为例,安装stomp.py: https://github.com/jasonrbriggs/stomp.py 下载后安装: python setup.py install 很简单,然后一个简单的示例: import time import sys import stomp class MyListener(object): def on_error(self, headers, message): print('received an error

原!!win7-64 安装python的 redis客户端库

安装python的redis客户端库 本人系统已装python2.7 利用cmd命令行: 1.cmd-->python -->>>进入python命令下 >>>from urllib import urlopen >>>data = urlopen('http://peak.telecommunity.com/dist/ez_setup.py') >>>open('ez_setup.py','wb').write(data.re

Spring+Stomp+ActiveMq实现websocket长连接

stomp.js+spring+sockjs+activemq实现websocket长连接,使用java配置. pom.xml(只列出除了spring基本依赖意外的依赖,spring-version为4.3.3.RELEASE): <dependency> <groupId>javax.websocket</groupId> <artifactId>javax.websocket-api</artifactId> <version>1

基于thrift的java和python分别作为客户端和服务端的调用实现

前面已经实现了纯java的thrift的实现. 现在实现实现一下python作为客户端和服务端的thrift的调用 1.python作为客户端,java作为服务端 java服务端代码参考前面写的博客 客户端python的准备: 1.使用mac下的PyCharm,专业的python开发工具 2.生成python代码 thrift --gen py thrift/data.thrift 3.在mac下安装thrift的python依赖 sudo python setup.py install 安装t

【Python】 http客户端库requests &amp; urllib2 以及ip地址处理IPy

requests requests是个HTTPClient库,相比于urllib,urllib2等模块比更加简洁易用 ■ get请求 作为示例,讲一下关于requests如何发起并处理一个get请求 r = requests.get("http://www.baidu.com") #可以加入timeout参数来设置超时 r是一个Response对象,可以用r查看很多信息 如r.status_code 查看本次请求的http返回码 r.headers 头部信息(是个类字典对象) r.ur

python中通过客户端IP拿到所在城市和当地天气信息—附带项目案例

熟悉老一代QQ的小伙伴可能都知道,很早以前的QQ,鼠标滑到头像的位置,你的位置和IP会在详情页显示,那么这个是如何做到的呢?下面我们就来玩一玩这个东西 首先,需求分析: 1.拿到客户端IP 2.通过IP拿到客户端所在地区 3.通过地区拿到当地天气 4.整合功能,展示给用户 第一步,如何拿到用户IP 我们以Django环境为例 # 客户端的请求,IP信息会在请求头中 request.META['REMOTE_ADDR'] # 或 request.META.get('HTTP_X_FORWARDED

Python可以用于客户端Web开发吗?

N00b在Python,但我有大量的PHP经验,并希望扩展我的技能. 我知道Python在服务器端执行方面很出色,只是想知道客户端. 解决方案 你看过skulpt吗? http://www.skulpt.org/ 本文首发于Python黑洞网,博客园同步跟新 原文地址:https://www.cnblogs.com/pythonzhichan/p/11431508.html

python实现一个客户端与服务端的通信

函数介绍 Socket对象方法: 服务端: 函数 描述 .bind() 绑定地址关键字,AF_INET下以元组的形式表示地址.常用bind((host,port)) .listen() 监听TCP,可以挂起的最大连接数,该值至少为1,一般设为5即可 .accept() 被动接受TCP客户端的连接 客户端: 函数 描述 .connect() 初始化服务器连接 .connect_ex() 是对connect()函数的扩展,当出错时返回出错码,不报异常 其它函数: 函数 描述 .recv() 接收数据

python实现redis客户端单例+hbase客户端单例

当业务需要大量去连接redis或者hbase的时候,大量的连接会造成socket的大量占用,导致的结果就是服务器没有更多的端口去分配,这种情况下的最好解决方案就是实现客户端连接的单例模式,保持连接永远是同一个.说到这,可能大家没有经历过,如果在每秒钟插入4000条数据的话,这个现象就非常明显了.下面就实现下python实现操作redis+hbase单例模式,有很多改进之处,根据自己业务进行调整,可以通过打印实例的ID进行验证: import happybase import redis clas