基于python使用tibco ems代码实例
2019-12-24 12:11
721 查看
这篇文章主要介绍了基于python使用tibco ems代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
TIBCO Enterprise Message Service 是一个消息服务器产品
完全支持JMS的通讯协议,在运行速度和消息吞吐量上表现非常出色,
对于Windows、Linux、Mac、AIX平台都提供支持
代码如下
#encoding=utf-8 import jpype jvmpath=r"C:\Program Files\Java\jre1.8.0_161\bin\server\jvm.dll" class EmsHelper(object): def __init__(self, server= "tcp://localhost:7222",user="admin",pwd=""): gemsjar = r"E:\EDriver\software\JAVA\jar\Gems.jar;D:\tibco\bw5\ems\8.2\lib\tibjms.jar;D:\tibco\bw5\ems\8.2\lib\tibcrypt.jar;D:\tibco\bw5\ems\8.2\lib\slf4j-api-1.4.2.jar;D:\tibco\bw5\ems\8.2\lib\slf4j-simple-1.4.2.jar;D:\tibco\bw5\ems\8.2\lib\tibjmsadmin.jar;D:\tibco\bw5\ems\8.2\lib\jms-2.0.jar;D:\tibco\bw5\ems\8.2\lib\jndi.jar" #gemsjar = r"D:\tibco\bw5\ems\8.2\lib\jms-2.0.jar;E:\EDriver\software\JAVA\jar\tibjms.jar" jvmArg = "-Djava.class.path=.;%s" % gemsjar jpype.startJVM(jvmpath,jvmArg) self.TibjmsConnection = jpype.JClass('com.tibco.tibjms.TibjmsConnection') self.TibjmsConnectionFactory = jpype.JClass('com.tibco.tibjms.TibjmsConnectionFactory') def SendQueueMsg(self,qname="testq",msgstr=str({'id':1,'name':"tname"})): connfac = self.TibjmsConnectionFactory(server) conn=connfac.createConnection(user,pwd) session=conn.createSession(0,1) dest=session.createQueue(qname) msgProducer = session.createProducer(None) msg = session.createTextMessage() msg.setText(msgstr) msgProducer.send(dest, msg) conn.close() def ShowQueueMsg(self,qname="testq",maxlen=5): connfac = self.TibjmsConnectionFactory(server) conn=connfac.createConnection(user,pwd) session=conn.createSession() queue = session.createQueue(qname) browser = session.createBrowser(queue) msgs = browser.getEnumeration() num = 0 while(msgs.hasMoreElements()): num+=1 message =msgs.nextElement() print message.getText() if(num>=maxlen): break browser.close() conn.close() def HandleOneQueueMsg(self,qname="testq"): connfac = self.TibjmsConnectionFactory(server) conn=connfac.createConnection(user,pwd) session=conn.createSession() queue = session.createQueue(qname) dest=session.createQueue(qname) msgConsumer = session.createConsumer(dest) conn.start() msg = msgConsumer.receive() msg.acknowledge() self.HandleMsg(msg.getText()) conn.close() def HandleMsg(self,msgstr): print "message is : ",msgstr if __name__ == '__main__': server,user,pwd,qname,msgstr="tcp://localhost:7222","admin","","testq",str({'id':1,'name':"tname"}) eh=EmsHelper(server,user,pwd) eh.HandleQueueMsg()
以上就是本文的全部内容,希望对大家的学习有所帮助
您可能感兴趣的文章:
相关文章推荐
- Python中使用PyQt把网页转换成PDF操作代码实例
- python中集合类型创建、更新、删除、修改以及操作符使用实例代码
- 代码笔记 | 基于Python的净值数据接口调用代码实例
- python 使用MySQL数据库的实例代码
- Python使用requests发送POST请求实例代码
- python使用xlrd和xlwt读写Excel文件的实例代码
- Python csv模块使用方法代码实例
- 基于Python使用SVM识别简单的字符验证码的完整代码开源分享
- java使用RandomAccessFile类基于指针读写文件实例代码
- 基于Python socket的端口扫描程序实例代码
- Python中如何使用if语句处理列表实例代码
- python3使用print打印带颜色的字符串代码实例
- 使用python脚本自动创建pip.ini配置文件代码实例
- python使用正则搜索字符串或文件中的浮点数代码实例
- Python使用list的append和pop方法创建堆栈和队列实例代码
- 使用Python对Csv文件操作实例代码
- python使用pil进行图像处理(等比例压缩、裁剪)实例代码
- 使用Python操作excel文件的实例代码
- Python使用装饰器进行django开发实例代码
- 使用Python写一个贪吃蛇游戏实例代码