ActiveMQ-API(一)

1:Connection方法的使用：
在成功创建正确的ConnectionFactory后，下一步将是创建一个连接，它是JMS定义的一个接口，ConnectionFactory负责返回可以与底层消息传递系统进行通信的Connection实现。通常客户端只是用单一的连接，根据JMS文档，Connection的目的是“利用JMS提供者封装开放的连接”，以及表示“客户端与提供者服务例程之间的开放tcp/ip套接字”。该文档还指出Connection应该是进行客户端身份验证的地方等等。
当一个Connection被创建时，它的传输默认是关闭的，必须使用start方法开启，一个Connection可以创建一个或者多个的Session。
当一个程序执行完成后，必须关闭之前创建的Connection，负责ActiveMQ不能释放资源，关闭一个Connection同样也关闭了Session，MessageProducer和MessageConsumer。
Connection createConnection();
Connection createConnection(String username,String password);
2:Session方法使用
一旦从ConnectionFactory中获得一个Connection,必须从Connection中创建一个或者多个Session。Session是一个发送或接受消息的线程，可以使用Session创建MessageProducer,MessageConsumer和Message。
Session可以被事务化，也可以不被事务化，通常，可以通过向Connection上的适当创建方法传递一个布尔参数对此进行设置。
Session createSession(boolean transacted,int acknowledgeModel);
其中transacted为使用事物标识，acknowledgeModel为签收模式。
结束事务有两种方法：提交或者回滚。当一个事务提交，消息被处理。如果事务中有一个步骤失败，事务就回滚，这个事务中的已经执行的动作将被撤销。在发送消息最后也必须要使用session.commit()方法提交事务。
签收模式有三种：
Session.AUTO_ACKNOWLEDGE当客户端从receive和onMessage成功返回时，Session自动签收客户端的这条消息的收条。
Session.CLIENT_ACKNOWLEDGE客户端通过调用消息（Message）的acknowledge方法签收消息。在这种情况下，签收发生在Session层面：签收一个已经消费的消息会自动签收这个Session中所有已消费的消息的收条。
Session.DUPS_OK_ACKNOWLEDGE此选项指示Session不必确保对传送消息的签收。它可能引起消息的重复，但是降低了Session的开销，所以只有客户端能容忍重复的消息，才可使用。代码测试：

package bhz.mq.helloworld;

import java.util.concurrent.TimeUnit;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {

    public static void main(String[] args) throws Exception{
        //第一步：建立ConnectionFactory工厂对象，需要填入用户名，密码，以及要链接的地址，均使用默认即可，默认的端口为"tcp://localhost:61616"
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("bhz","bhz","tcp://localhost:61616");
        //第二步：通过ConnectionFactory工厂对象我们创建一个Connection链接，并且调用Connection的start方法开启链接，Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();
        //第三步：通过Connection对象创建Session会话（上下文环境对象）,用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般我们设置自动签收。
        Session session = connection.createSession(Boolean.FALSE, Session.CLIENT_ACKNOWLEDGE);
        //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中
        Destination destination = session.createQueue("first");
        //第五步：我们需要通过Session对象创建消息的发送和接收对象（生产者和消费者）MessageProducer/MessageConsumer
        MessageProducer producer = session.createProducer(null);
        //第六步：我们可以使用MessageProducer的setDeliveryMode方法为其设置持久化特性和非持久化特性（DeliveryMode）,我们稍后介绍。
        //producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
        //第七步：最后我们使用JMS规范的TextMessage形式创建数据（通过Session对象），并用MessageProducer的send方法发送数据，同理客户端使用receive方法进行接收数据。
        for (int i=0;i<10;i++) {
            TextMessage msg = session.createTextMessage("我是消息内容"+i);
            //第一个参数 目标地址
            //第二个参数 具体的数据信息
            //第三个参数 传送数据的模式
            //第四个参数 优先级
            //第五个参数 消息的过期时间
            producer.send(destination,msg);
            
            TimeUnit.SECONDS.sleep(1);
        }
        if (connection != null) {
            connection.close();
        }
    }
    
}

package bhz.mq.helloworld;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {

    public static void main(String[] args) throws Exception {
        //第一步：建立ConnectionFactory工厂对象，需要填入用户名，密码，以及要链接的地址，均使用默认即可，默认的端口为"tcp://localhost:61616"
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("bhz","bhz","tcp://localhost:61616");
        //第二步：通过ConnectionFactory工厂对象我们创建一个Connection链接，并且调用Connection的start方法开启链接，Connection默认是关闭的。
        Connection connection = connectionFactory.createConnection();
        connection.start();
        //第三步：通过Connection对象创建Session会话（上下文环境对象）,用于接收消息，参数配置1为是否启用事务，参数配置2为签收模式，一般我们设置自动签收。
        Session session = connection.createSession(Boolean.FALSE, Session.CLIENT_ACKNOWLEDGE);
        //第四步：通过Session创建Destination对象，指的是一个客户端用来指定生产消息目标和消费消息来源的对象，在PTP模式中,Destination被称作Queue即队列，在发布订阅模式中就是Topic
        Destination destination = session.createQueue("first");
        //第五步：通过Session创建MessageConsumer
        MessageConsumer consumer = session.createConsumer(destination);
        while (true) {
            TextMessage msg = (TextMessage) consumer.receive();
            //手动签收
            msg.acknowledge();
            System.out.println("消费数据："+msg.getText());
        }
    }
    
}