基于python使用tibco ems代码实例
这篇文章主要介绍了基于python使用tibcoems代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
TIBCOEnterpriseMessageService是一个消息服务器产品
完全支持JMS的通讯协议,在运行速度和消息吞吐量上表现非常出色,
对于Windows、Linux、Mac、AIX平台都提供支持
代码如下
#encoding=utf-8 importjpype jvmpath=r"C:\ProgramFiles\Java\jre1.8.0_161\bin\server\jvm.dll" classEmsHelper(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') defSendQueueMsg(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() defShowQueueMsg(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() printmessage.getText() if(num>=maxlen): break browser.close() conn.close() defHandleOneQueueMsg(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() defHandleMsg(self,msgstr): print"messageis:",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()
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。