老人被骗255万,带你看星星,angel baby
在一些场景下rpc的同步方式可能不太适合业务逻辑的处理，并且这种方式在某些场景下会导致业务的紧耦合。
基于异步交互模型的jms解决了rpc产生的紧耦合问题，它提供了一个可以通过网络访问的抽象消息队列。
jms应用由以下几个部分组成：
- a jms provider: a messaging system that implements the jms specification.
- jms clients: java applications that send and receive messages.
- messages: objects that are used to communicate information between jms clients.
- administered objects: preconfigured jms objects that are created by an administrator for the use of jms clients.
jms支持两种消息模型
point to point (queuing)
publish-subscribe （topic）
在jms应用中，一个消息由三部分组成：header，properties，body。
我要评论消息头，必填，包含了路由信息和标识信息。属性，可选，由key-value对构成，可以看做是对header的扩展。消息体，可选，包含真正要传递的数据。jms规范定义了jms provider必须要支持的六种消息类型:
点对点队列api
发布-订阅api
使用jndi找到connectionfactory对象，或者直接实例化一个connectionfactory，最终得到一个queueconnectionfactory或者topicconnectionfactory的实例，通过这个实例为生产者创建连接。
使用jndi查找连接工厂对象：
context ctx = new initialcontext();
connectionfactory cf1 =(connectionfactory)ctx.lookup("jms / queueconnectionfactory");
connectionfactory cf2 = (connectionfactory) ctx.lookup("/jms/topicconnectionfactory");
直接实例化连接工厂：
connectionfactory connfactory = new com.sun.messaging.connectionfactory();
使用connectionfactory创建连接connection。
connection connection = connfactory.createconnection();
注意：调用结束后调用
connection.close()关闭所有已经创建的连接。
使用connection对象创建session。这些session将一组发送和接收合并到一个原子单元内，并提供事务上下文。
session session = connection.createsession(false, session.auto_acknowledge);
createsession()方法有两个参数：第一个表示session是否使用事务，第二个表示session在成功收到消息后自动确认。
使用jndi查找destination对象，或者直接实例化destination。
客户端使用destination对象来指定它消费的消息的来源或者它生产的消息的目标。在point to point消息传递中，destination为queue，在消息传递的发布/订阅模型中，为topic。
jndi方式：
destination dest = (queue) ctx.lookup("jms/somequeue");
直接实例化：
queue q = new com.sun.messaging.queue("world"); 通过session和destination创建messageproducer，messageproducer用来发送消息。下面的代码中没有说明destination的使用，但是每一个消息必须指定destination。
messageproducer producer = session.createproducer(somequeue or sometopic);
完成生产者创建之后，就可以使用生产者发送消息
producer.send(message);
1.2.3.4 同producer
消息的消费分为同步消费和异步消费两种。同步消费是使用receive()方法，而异步消费则使用消息监听器，messagelistner。
通过session和destination创建messageconsumer，messageproducer用来接收消息。
messageconsumer consumer = session.createconsumer(somequeue or sometopic);
如果是一个发布/订阅模式的消费者，可以使用session.createdurablesubscriber()创建一个持久的topic订阅者。
和producer同样，创建之后可以使用其功能，不同的是messageconsumer不是主动模式，而是被动模式。在启动连接之前，消息不会传递，必须先启动连接，才能接收消息。
connection.start(); message msg = consumer.receive();
consumer.receive()可传入一个long型参数来指定超时时间，单位是ms。
注意：使用
receive()方法是同步消费，异步消费需要使用消息监听器。
如果需要异步通信，需要实例化messagelistener并在messageconsumer中注册这个监听器。
messagelistener listener = new mylistener(); consumer.setmessagelistener(listener);
为了避免丢失消息，注册监听器后，调用连接的start()方法，当消息开始传递，jms会自动调用监听器的onmessage()接收消息。
如对本文有疑问，请在下面进行留言讨论，广大热心网友会与你互动！！ 点击进行留言回复
浅析我对 String、StringBuilder、StringBuffer 的理解
使用IDEA搭建SSM框架的详细教程(spring + springMVC +MyBatis)
Springboot整合freemarker 404问题解决方案
引入mybatis-plus报 Invalid bound statement错误问题的解决方法
网友评论