这节开始动手写程序，首先写一个简单的P2P通信模式（点对点）的消息队列。分为以下几步

1. 引入pom依赖

作为一个简单实例，先引入一个activemq-core

<dependencies>

<dependency>

<groupId>org.apache.activemq</groupId>

<artifactId>activemq-core</artifactId>

<version>5.7.0</version>

</dependency>

</dependencies>

2. 编写消息生产者端（Producer）生产消息

对应例子工程：activemqprovider1

类似于JDBC那几步：

1)创建连接工厂（ConnectionFactory）

2）通过连接工厂创建（到消息队列服务器的）连接(Connection)

3）启动连接(start connection)

4）通过连接创建一个会话（Session）

5）通过会话创建一个目的地（消息队列）

6）通过会话创建一个消息生产者（MessageProducer）

7) 通过会话创建一到多条消息(Message)，通过消息生产者发送出去

8）关闭会话和连接(close session,close connection),同JDBC类似，用完释放资源

通过管理控制台来观察

消息生产端未启动前，一个queue（队列）都没有

生产端启动后，创建了一个消息队列，并存在一个待消费消息（入队数量为1，出队为0）

3. 编写消息消费者端(Consumer)消费消息 

有生产就得有消费，消息才有意义，下面我们编写消息消费者端

对应例子工程：activemqconsumer1

大部分过程同生产者端一样

1)创建连接工厂

2）通过连接工厂创建（到消息队列服务器的）连接

3）启动连接

4）通过连接创建一个会话（Session）

5）通过会话创建一个目的地（消息队列）

6）通过会话创建一个消息消费者（MessageConsumer）

7) 通过会话创建一到多条消息，通过消息生产者发送出去

8）关闭会话和连接

再次观察控制台

启动消费者端消费消息后，待消费消息数量变为0，出队消息增加为1（表示已消费）

再次启动消费者端，发现进程一直阻塞，因为没有新消息可以消费

在消息中传递额外属性

生产消息时除了包装消息内容外，也可以设置一些其他属性表示对消息的额外说明。

生产方通过消息对象的setXXXProperty方法设置属性，XXX表示不同的数据类型

消费方通过消息对象的getXXXProperty方法获取属性

请大家自行实验并观察控制台