1.1 java消息服务:不同系统之间的信息交换，是我们开(3)

名称之前添加Queue一词。一般来说，使用点对点消息传送模型的应用程序将使用基于队列的API，而不使用公共API。

JMS发布/订阅API:

发布/订阅消息传送模型API是指JMS

createjs是adobe官方赞助的开源开发框架，它大部分 api都是基于flash原有的api来模仿实现的，并且官方提供了直接把flash转成js数据包的工具，调用起来很方便。架构组将产品功能拆分为若干微服务，为每个微服务设计 api 接口（例如 rest api），需要给出 api 文档，包括 api 的名称、版本、请求参数、响应结果、错误代码等信息。在开发阶段，开发工程师去实现 api 接口，也包括完成 api 的单元测试工作，在此期间，前端工程师会并行开发 web ui 部分，可根据 api 文档造出一些假数据（我们称为“mock 数据”），这样一来，前端工程师就不必等待后端 api 全部开发完毕，才能开始自己的工作了，实现了前后端并行开发。

在0.8版本之后，每一个woker绑定一个inbound transfer queue和outbond queue，inbound queue用于接收message，outbond queue用于发送消息。 // and the message is the earliest asynchronous message in the queue.。

的API，因此在大多数情况下，Queue这个词会由Topic取代。

2.4 ActiveMQ点对点发送与接收消息示例

2.4.1 简单示例:

写一个采用Queue队列方式点对点发送接收文本信息的Demo,先写发送者,如下:

packagecom.kinglong.activemq.queue;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**

* 消息发送者

*

*/

public class Sender {

/**消息服务器的连接地址**/

public static final String BROKER_URL = "tcp://192.168.174.129:61616";

public static void main(String[] args) {

Sender sender = new Sender();

sender.sendMessage("Hello ActiveMQ.");

}

/**

* 发送消息

*

* @param msg

*/

public void sendMessage (String msg) {

Connection connection = null;

Session session = null;

MessageProducer messageProducer = null;

try {

//1.创建一个连接工厂

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);

//2.创建一个连接

connection = connectionFactory.createConnection();

//3.创建一个Session

session = connection.createSession(Boolean.FALSE,Session.AUTO_ACKNOWLEDGE);

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-94236-3.html