消息中间件MQ之ActiveMQ学习总结(上)

ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。

MQ:message queue,称之为消息中间件,又叫消息队列。 以双方约定好的方式,接收发送消息,用于网络间的传输;

核心特性:

1.解耦

2.异步

3.降流

MQ的同类产品:

kafka: 大数据

RabbitMQ:Erlang语言,协议是AMQP(Advanced Message Queueing Protoco)

RocketMQ:阿里封装

ActiveMQ :Java语言,协议是JMS(Java Messaging Service )

官网地址-http://activemq.apache.org

下载Linux版本,用于支持高可用

1.上传至/opt目录下,解压

2.配置环境变量

3.启动命令:./activemq start

4:默认后端端口号61616,程序8161

5.进入网页控制台:localhost:8161/admin user:admin pw:admin

安装成功!

从上面的信息简单看下:首页|队列|主题|订阅|连接|网络|调度|发送

用于显示消息的管理。

MQ-HelloWord

引入坐标

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-activemq</artifactId>
   <exclusions>
      <exclusion>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-log4j12</artifactId>
      </exclusion>
   </exclusions>
</dependency>

<dependency>
   <groupId>org.apache.activemq</groupId>
   <artifactId>activemq-pool</artifactId>
   <version>5.15.2</version>
   <exclusions>
      <exclusion>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-log4j12</artifactId>
      </exclusion>
   </exclusions>
</dependency>

消息:

创建提供者:

package com.atkk.Controller;


import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @author zhaokkstart
 * @create 2019-06-23 16:17
 */
public class MQProduce {
    private static final  String ACTIVEMQ_URL="tcp://192.168.235.128:61616";
    private static final  String ACTIVEMQ_name="zhaokk";

    public static void main(String[] args) throws JMSException {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(ACTIVEMQ_name);
        MessageProducer producer = session.createProducer(queue);
        for (int i = 0; i < 3; i++) {
            TextMessage textMessage = session.createTextMessage("mq消息" + i);
            producer.send(textMessage);
        }
        producer.close();
        session.close();
        connection.close();
        System.out.println("---消息发布");
    }
}

消息的消费者:

package com.atkk.Controller;


import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * @author zhaokkstart
 * @create 2019-06-23 16:17
 */
public class MQConsumer {
    private static final  String ACTIVEMQ_URL="tcp://192.168.235.128:61616";
    private static final  String ACTIVEMQ_name="zhaokk";

    public static void main(String[] args) throws JMSException {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);
        Connection connection = connectionFactory.createConnection();
        connection.start();

        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Queue queue = session.createQueue(ACTIVEMQ_name);
        MessageConsumer consumer = session.createConsumer(queue);
        while(true){
            TextMessage receive = (TextMessage) consumer.receive();
                if(null!=receive){
                    System.out.println("接受消息"+receive.getText());
                }else{
                    break;
                }
        }
        consumer.close();
        session.close();
        connection.close();
        System.out.println("---消息接受");
    }


}

当发送消息后,队列应出现一个提供者,3条消息

当接收消息后,队列应出现一个消费者,接收消息

JMS开发的基本步骤:

消息模式:

点对点:一对一

订阅:一对多

消息默认是用不过期的,

消息的可靠性 如何保证

1.持久性

2.事务

3.签收 Acknowledge

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

这里的boolean就是是否开启事务,后面的就是签收方式为自动签收构造方法:

构造方法:

其中:

void setDeliveryMode(int var1) throws JMSException;

持久化方法:DeliveryMode.PERSISTENT传入int值表示支持持久化

特点:队列的消息只能消费一次

总结:这种三种角色的技术理念,

类比dubbo的提供者,注册中心,消费者

redis的主从机制等理念,技术选型需要有消息订阅,降低系统负担,异步解耦的痛点,从而并不是所有业务场景都适合与MQ。

ActiveMQ的官方文档:

http://activemq.apache.org/components/classic/documentation

对比与所有中间件的功能,维度,可理解其他产品的使用,

RabbitMQ 推荐CSDN博主:CherryCHong的博客地址

https://blog.csdn.net/a1786223749/article/details/86138970

原文发布于微信公众号 - 赵KK日常技术记录(gh_cc4c9f1a9521)

原文发表时间:2019-06-23

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

扫码关注云+社区

领取腾讯云代金券