activeMq-helloworld-01

activemq 是JMS 规范的一种实现，我们先不讨论JMS，也不先讨论应用场景，我们先来感受一下这个消息中间件是怎么玩的。

安装（略）---百度

1.1 启动：win （不要究竟是否在linux 上，最简单的先玩起来）

./bin/activemq start

访问：http://127.0.0.1:8161/admin 后台管理，默认密码 admin/admin

2: java 客户端操作

maven:
        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.15.13</version>
        </dependency>

java:
// p2p helloworld 点对点通信，消息发送者, 类比 jdbc 

public class HelloWorldSender {

    public static void main(String[] args) throws JMSException {

        //1.客户端连接到服务器
        ConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
        //2.创建一次连接
        Connection connection = activeMQConnectionFactory.createConnection();
        //3.开启
        connection.start();
        //4. 创建session 对象
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5. 创建一个队列
        Queue queue = session.createQueue("test-hello");
        //6. 创建消息发送者
        MessageProducer producer = session.createProducer(queue);
        //7. 发送消息
        producer.send(session.createTextMessage("hello world"));
        //关闭资源
        producer.close();
        session.close();
        connection.close();
    }
}

上面是我们使用activemq 实现了一个简单的p2p 的消息投递，主要涉及对象：

ConnectionFactory : 连接工厂，就是连接到activemq 服务端（C/S 架构）

Connection : 由ConnectionFactory 创建来的一个连接

Session : 由 Connection 创建而来的一个session 对象，表示一次和服务端的会话

Queue : 由 Session 创建的一个队列，用来存储消息。

MessageProducer : 消息发送者

java: 消费者
public class HelloWorldCustomer {
    public static void main(String[] args) throws JMSException {
        //1. 创建连接工厂
        ConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
        //2.创建一个连接
        Connection connection = activeMQConnectionFactory.createConnection();
        //3.开启
        connection.start();
        //4.创建一个session
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //5.创建一个Queue 队列
        Queue queue = session.createQueue("test-hello");
        // 6.消费消息
        MessageConsumer consumer = session.createConsumer(queue);
        TextMessage message = (TextMessage) consumer.receive();
        String messageText = message.getText();
        System.out.println(messageText);
        // 关闭资源
        consumer.close();
        session.close(); 
        connection.close(); 
    }
}

上面我们创建了一个消费者。

我们现在对activemq 中间件有了最初步的认识，接下来我们就来说一下 JMS 规范，运用场景的话简单说一下：系统内部解耦，多系统通信，分布式事务，流量削峰。。。
JMS: (百度)
JMS即Java消息服务（Java Message Service）应用程序接口，是一个Java平台中关于面向消息中间件（MOM）的API，用于在两个应用程序之间，或分布式系统中发送消息，进行异步通信。Java消息服务是一个与具体平台无关的API，绝大多数MOM提供商都对JMS提供支持。
简单点说：就是JMS 是定义消息中间的开发规范 api ,比如jdbc 一样，有很多实现。activemq 就是jms 规范的实现之一。

jms 具体内容：

架构体系组成，也就是构造角色有：

jms 服务端（activemq server 服务器）
jms 客户端 (activemq client)
jms 消息发送者（MessageProducer ）
jms 消息消费者（MessageConsumer ）
jms 队列（Queue ）
jms 主题（Topic）
jms 消息（Message）

上面的jms 规范定义了这些组成角色，也就是说，如果 jms 规范的实现必须要有以上实现以上角色的对象。

抽象出的编程接口 api ：

ConnectionFactory 接口（连接工厂）
Connection 接口（连接）
Destination 接口（目标）--- activemq 中的 Queue 或者 Topic
Session 接口（会话）
MessageProducer 接口（消息生产者）
MessageConsumer 接口（消息消费者）
Message 接口（消息）

是否对对编程接口非常熟悉？是的，我们可以在 helloworld 中可以找到这些对象，也说明了 activemq 就是对jms 规范的实现。

消息通信模型：

p2p 点对点模式
topic 发布/订阅模式

上面是jms 规定的消息模型，也是activemq 中的两种消息模型。具体的点对点或者topic 具有的特点，我们会在后面说明。如迫不及待想知道，可以百度查询。上诉jms规范来自百度，仅为个人解读。