消息的生产和消费

一、队列/主题 对比

二、jms是什么

JavaEE是一套使用Java进行企业级应用开发的大家遵守的13个核心工业标准。JavaEE平台提供的一组基于组件的方法来加快设计，开发，装配以及企业部署应用程序

1. JDBC（Java Database）数据库连接

2. JDNI（Java Naming and Directory）的名命和目录接口

3. EJB（Enterprise JavaBean）

4. RMI（Remote Method Invoke）远程方法调用

5. Java IDL（Interface Description Language）/CORBA（Common Object Broker Arcgitecture）接口定义语言/公用对象请求代理程序体系结构

6. JSP（Java Server Page）

7. Servlet

8. XML（Extensible Markup Language）可扩展标记语言

9. JMS（Java Transaction Service）Java消息服务

10. JTA（Java Transaction API）Java事务API

11. JTS（Java Transaction Service）Java事务服务

12. JavaMail

13. JSAF（JavaBean Activation Framework）

什么是Java消息服务

Java消息服务是指两个应用程序之间进行异步通讯的API，它为标准消息协议和消息服务提供了一组通用接口，包括创建，发送，读取消息，用于JAVA的应用程序开发，在JavaEE中，当连个程序使用JMS进行通讯是，他们之间并不是直接相连的，二十通过消息的手法组件关联起来以达到解耦异步削峰的效果

jms落地产品

Active MQ

Rabbit MQ(Erlang)

Rocket MQ(阿里)

Kafka(大数据)

jms组成元素

Provider : MQ服务器

Producer : 消息的生产者

Message : 消息

Consumer : 消费者

Message格式

• 消息头

  TextMessage textMessage = session.createTextMessage("msg" + i);
  ?
  //目的地队列或者主题
  textMessage.setJMSDestination();
  ?
  //消息持久和非持久,持久消息之发送一次，宕机之后消息也不会丢失
  textMessage.setJMSDeliveryMode();
  ?
  //过期时间 0永不过期
  textMessage.setJMSExpiration();
  ?
  //消息的优先级0~9，0~4是普通默认4，消息的加急
  textMessage.setJMSPriority();
  ?
  //id唯一识别有中间件产生
  textMessage.setJMSMessageID();
  ?
  //send也可以统一的批处理
  textMessage.send();

• 消息体

  • 封装具体的消息数据

           
  //普通字符串
  session.createTextMessage();
  //二进制数组消息包含一个byte[]
  session.createBytesMessage();
  //java数据流消息，标准流炒作来顺序的填充和读取
  session.createStreamMessage();
  //一个map类型的下拍戏，key为string，值为java的基本类型
  session.createMapMessage();
  //对象消息包含一个可序列化的java对象
  session.createObjectMessage();

• 消息属性

  消息头的扩展

  //消息属性
  textMessage.setStringProperty();
  textMessage.setBooleanProperty();

可靠性之非持久化

1. 持久

2. 事务

   事务偏生产者，签收偏消费者

3. 签收

整合spring/springboot

activemq的传输协议

nio

tcp

持久化机制

kahadb：5.4‘以后的默认基于日志文件的消息存储（类似于redis持久化的aof）

消息存储使用一个事务日志，和仅仅用一个索引文件来储存他所有的地址

<persistenceAdapter>
    <kahaDB direcory="${activemq.data}/kahadb"></kahaDB>
</persistenceAdapter>

jdbc

环境搭建

1. 添加mysql驱动包（包括连接池druid）到mq的lib文件夹

2. jdbc持久化配置

   <persistenceAdapter>
       <!-- 默认的配置
               <kahaDB directory="${activemq.data}/kahadb"/>
      -->
       <!-- 配置jdbc持久化的方法-->
       <jdbcPersistenceAdapter dataSource="#mysql-ds" createTablesOnStartup="true"/>
   </persistenceAdapter>

3. 创建数据源在active.xml,broker标签之后。import标签之前

   <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
       <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
       <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
       <property name="username" value="root"/>
       <property name="password" value="root"/>
       <property name="poolPreparedStatements" value="true"/>
   </bean>

4. 创建数据库activemq

5.  启动 MQ 然后查看数据库

有关于Active MQ的笔记

原文：https://www.cnblogs.com/yangenyu/p/12070392.html