ActiveMq笔记

MQ消息中间件：
    1、入门概述：
    2、ActiveMq的安装和控制台
    3、java编码实现ActiveMQ   
Elasticsearch:
    kafka produce --- zk --- client 

  mq的种类：
    kafka
    rabittmq 
    rocketmq 
    
    activemq的技术维度 
       :落地的细节有不一样。
       API发送和接收 
       mq的高可用性
       mq的集群和容错配置
       mq的持久化 
       延时发送/定时投递 
       签收机制
       spring整合 
     
     activeMQ的作用：
        削峰
        解耦
        异步 
        
    
    kafka 
        编程语言：java/scala 
    rabbitmq:
        erlang 
    rocketmq:
        java 
    
    notify 
    broker ：activemq的实例 
    功能：实现高可用、可性能、可伸缩、易用和安全的企业
    异步消息的消费和处理。
    控制消息的顺序
    可以和spring和springboot整合简化编码
    配置集群容错的mq集群
    
    3、安装步骤
        官网下载
        /opt目录下面
        解压缩 activeMQ tar.gz 
        
    4、主题    
    

消息对列的模式特性：
    1、点对点
    2、消息发布订阅模式
在点对点的消息传递域中，目的地称为队列（queue）
在发布订阅消息传递域中，目的地称为主题（topic）

    4.0.0

    org.example
    mavenproject
    1.0-SNAPSHOT


    
        org.apache.activemq
        activemq-all
        5.15.15
    

    
        org.apache.xbean
        xbean-spring
        3.16
    

    
        org.apache.xbean
        xbean-spring
        3.16
    

    
        org.slf4j
        slf4j-api
        1.7.25
    
    
        ch.qos.logback
        logback-classic
        1.1.2
    

    
        junit
        junit
        4.12
        test
    

生产者代码

package com.text.jms;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

public class JmsProduce {
    public  static final String hostname="localhost";
    public static final String port="61616";
    public static final String QUEUE_NAME="queue01";

    public static final String DEFAULT_BROKER_BIND_URL="tcp://"+hostname+":61616";
    public static void main(String[] args) throws JMSException {
        //1 创建连接工场
         ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory("admin","admin",DEFAULT_BROKER_BIND_URL);
        //通过联接工厂，获得连接
         Connection connection = activeMQConnectionFactory.createConnection();
         //创建连接
        connection.start();

        //3创建会话session
        //两个参数，第一个叫事务，第二个叫签收
        final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        //创建目的地（队列还是主题）
        Queue queue = session.createQueue(QUEUE_NAME);
        //5 创建消息的生产者
        MessageProducer messageProducer = session.createProducer(queue);
        for (int i = 0; i < 3; i++) {
            //7 创建消息，好比学生按照要求写好面试消息
             TextMessage textMessage = session.createTextMessage("msg--" + i);
            //8 通过messagePorudecder 发给msg
            messageProducer.send(textMessage);
        }
        messageProducer.close();
        session.close();
        connection.close();
        System.out.println("消息发布完成+++");


    }
}