`
YOUNG918
  • 浏览: 190102 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

openMQ学习

阅读更多

1,

myConnFactory = new com.sun.messaging.ConnectionFactory();

Connection myConn = myConnFactory.createConnection();

Session mySess = myConn.createSession(false, Session.AUTO_ACKNOWLEDGE);

myQueue = new com.sun.messaging.Queue("world");

MessageProducer myMsgProducer = mySess.createProducer(myQueue);

TextMessage myTextMsg = mySess.createTextMessage();

myTextMsg.setText("Hello World");
            System.out.println("Sending Message: " + myTextMsg.getText());
            myMsgProducer.send(myTextMsg);

 

MessageConsumer myMsgConsumer = mySess.createConsumer(myQueue);

Message msg = myMsgConsumer.receive();

 

2,

String MYCF_LOOKUP_NAME = "MyConnectionFactory";
String MYQUEUE_LOOKUP_NAME = "MyQueue";

Hashtable env = new Hashtable();

env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.fscontext.RefFSContextFactory");

env.put(Context.PROVIDER_URL, "file:///C:/Temp");

ctx = new InitialContext(env);

myConnFactory = (javax.jms.ConnectionFactory) ctx.lookup(MYCF_LOOKUP_NAME);

myQueue = (javax.jms.Queue)ctx.lookup(MYQUEUE_LOOKUP_NAME);

 

3,ConnectionFactory myFctry = new com.sun.messaging.ConnectionFactory();

myFctry.setProperty(ConnectionConfiguration.imqAddressList,
"localhost:7676, broker2:5000, broker3:9999");
myFctry.setProperty(ConnectionConfiguration.imqReconnectEnabled, "true");

 

 

Comannd:

imqbrokerd -tty
The -tty option causes all logged messages to be displayed to the terminal console.

imqcmd query bkr -u admin

to test a Broker

imqcmd purge dst -t destType -n destName

分享到:
评论

相关推荐

    openmq-4.4.2

    通过研究OpenMQ 4.4.2的源代码,开发者可以学习到如何设计和实现一个高效的消息中间件,包括队列管理、网络通信、并发控制、错误处理等关键技术。此外,对于希望为OpenMQ贡献代码的开发者,了解源代码也是必不可少的...

    habari-openmq-20190131-src.zip

    标题中的"habari-openmq-20190131-src.zip"表明这是一个源代码压缩包,发布日期为2019年1月31日,名...开发人员可以使用这个源码来学习如何在Delphi中实现与OpenMQ的集成,或者将其作为基础来构建自己的消息传递系统。

    openmq:OpenMQ

    你可以通过查阅这些文件来深入了解OpenMQ的内部工作原理,学习如何配置和部署OpenMQ服务器,以及如何编写使用JMS的Java应用程序。这将有助于你掌握如何利用OpenMQ来构建高效、可靠的分布式系统,并理解Java消息服务...

    第三届阿里中间件性能挑战赛初赛-《基于Open-Messaging实现进程内消息引擎》,代码仅供学习交流_pgc.zip

    代码库“alirace-openmq-master”作为本次挑战赛的参赛项目之一,为参与者提供了一个可以参考和学习的实践平台。项目名称中的“alirace”可能暗示该项目具有高效的性能和灵活的设计,这符合中间件性能挑战赛的核心...

    第三届阿里中间件性能挑战赛初赛-《基于Open-Messaging实现进程内消息引擎》,代码仅供学习交流.zip

    通过参与这次挑战赛,开发者们可以学习如何利用该协议来设计和实现一个高效的进程内消息引擎。 进程内消息引擎的设计目标是为了在单一进程内实现消息的生产和消费机制,它能够提供一种轻量级的消息传递方式,适用于...

    RocketMQ消息队列资料

    同时,RocketMQ还支持多种协议,包括OpenMQ、ActiveMQ等,兼容性良好。 6. **强大的监控与管理**:RocketMQ提供了一套完整的管理工具,包括消息推送、监控、报警等功能,便于运维人员对系统状态进行实时监控和问题...

    ActiveMQ.zip

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它是基于Java的,并且遵循开放消息传递协议(Open Message Broker Protocol,简称OpenMQ),广泛应用于分布式系统中的异步通信和解耦。ActiveMQ作为消息代理,...

    activeMq Api 文档

    ActiveMQ是Apache软件基金会开发的一款开源消息中间件,它遵循开放消息中间件协议(Open Message Broker API,简称OpenMQ API),提供高性能、可伸缩、可靠的消息传递服务。API文档是开发者理解和使用ActiveMQ的关键...

    mq产品对比

    这些产品包括:ActiveMQ、RabbitMQ、RocketMQ、Joram、HornetQ、OpenMQ、MuleMQ、SonicMQ以及ZeroMQ。我们将从多个维度对这些产品进行比较,以便于读者更好地理解不同MQ产品的特性和适用场景。 #### 二、重要指标...

Global site tag (gtag.js) - Google Analytics