RabbitMQ 安装(linux):

1.安装Erlang-----------------------------------------

RabbitMQ是基于erlang语言进行开发的，所以安装RabbitMQ之前需要先安装erlang语言

    1.1安装erlang前先安装Linux依赖库:-------------------

    [if !supportLists]1. [endif]yum -y install make gcc gcc-c++ kernel-devel     m4 ncurses-devel openssl-devel

    1.2 解压erlang压缩包文件:-------------------

           tar -zxvf otp_src_21.2.tar.gz -C /usr/local

    1.3配置-------------------

  （需要切换到解压目录下进行操作cd otp_src_21.2）

    然后输入./configure

    然后回车（进行配置的时候需要一定的时间）

    1.4编译-------------------

  （执行的时候需要一定的时间）

    配置完成之后直接输入命令：make

    1.5安装-------------------

    (执行的时候需要一定的时间)

    编译完成之后直接输入命令：make install

    1.6删除安装包-------------------

  （可以执行也可以不执行）

    rm -rf otp_src_21.2

    1.7验证erlang是否安装成功-------------------

          在命令行输入：erl如果进入了编程命令行则             表示安装成功，

          然后按ctrl + z 退出编程命令行；

2.安装RabbtiMQ-----------------------------------------

    2.1解压RabbitMQ的压缩包:-------------------

    tar -xvf rabbitmq-server-generic-unix-3.8.0.tar.xz  -C /usr/local/

    .tar.xz文件解压后就可以使用了，无需再编译安装；

    切换到安装目录的sbin目录下:-------------------

    2.2.启动RabbitMQ----------------------

     ./rabbitmq-server -detached

     -detached表示后台启动

     如果后台启动的时候报错：

     解决方案：

     进入

     vim /etc/hosts(添加一行映射 映射当前服务器的ip地址与当前的主机host        名字)

     注意：为什么这里写的ip地址是192.168.65.131

     因为当前rabbitmq需要在这台服务器上使用

     为什么空格后面对应的内容写zookeeper

     因为当前这台服务器的hostname配置是zookeeper

     如何查看当前服务器的hostname的配置

     使用命令 cat /etc/hostname

     2.3启动后台web管理功能（需要切换到sbin目录下执行)-------

         ./rabbitmq-plugins enable rabbitmq_management

       然后通过http://192.168.65.131:15672访问默认

       用户guest、密码 guest，

        登录会提示User can only log in via localhost

        这里提示guest用户只能在本地登录，这个时候我们远程访问需要自己添          加用户和相应的权限。

        添加用户:./rabbitmqctl add_user admin admin

        这句话的意思是添加一个用户 账号是admin 密码是admin

        添加权限:./rabbitmqctl set_permissions -p "/" admin ".*" ".*" ".*"

        这句的意思是给所有的虚拟机主机添加所有的权限

        修改用户角色:./rabbitmqctl set_user_tags admin administrator

        这句话的意思是给admin添加一个标签 标签是administrator

        然后使用admin进行登录即可:

        2.4关闭rabbitmq服务器（切换到sbin目录下执行):-------------------

          ./rabbitmqctl shutdown

        2.5关闭后台web管理功能 :-------------------

        ./rabbitmq-plugins disable rabbitmq_management

RabbitMQ部分内容参考了： https://www.sojson.com/blog/48.html

---------------------------------------------------------------------------------

                        RabbitMQ提供方上传消息流程

1.启动后台web管理功能（需要切换到sbin目录下执行）-------------------

./rabbitmq-plugins enable rabbitmq_management

2.在需要使用RabbitMQ的API项目中导入依赖----------------------

<dependency>

<groupId>com.rabbitmq</groupId>

<artifactId>amqp-client</artifactId>

<version>5.8.0</version>

</dependency>

3.创建连接工厂---------------------------------------------------

 ConnectionFactory connectionFactory = new ConnectionFactory();

4.设置RabbitMQ安装的服务器的地址--------------------------------

connectionFactory.setHost("192.168.80.3");

5.设置RabbitMQ的端口号----------------------------------------

connectionFactory.setPort(5672);

6.设置登录用户和密码---------------------------------------

connectionFactory.setUsername("admin");          

 connectionFactory.setPassword("admin");

7.设置指定虚拟机:/为默认-----------------------------------

        connectionFactory.setVirtualHost("/");

8.创建与RabbitMQ服务的TCP链接-----------------------------

  connection = connectionFactory.newConnection();

9.创建于Exchange的通道,每个连接可以创建多个通道,每个通道代表一个会话任务----------------------------------------------------------

 channel = connection.createChannel();

10./*----------------------------------------------------------

    * 声明队列:如果RabbitMQ中没有此队列将自动创建

    * param1:队列的名称

    * param2:是否持久化(rabbit重启后,该队列是否还存在)

    * param3:队列是否独占此链接(其他队列不能使用此链接)

    * param4:队列不再使用时是否自动删除此队列

    * param5:队列参数(通常不需要)

    * */

            channel.queueDeclare("zhengxixi",true,false,false,null);

   11.编写要输送的消息------------------------------------------

            String data ="来自提供方的郑茜茜"+System.currentTimeMillis();

   12./*--------------------------------------------------------

    * 消息发布

    * param1:Exchange的名称,如果没有指定,则使用Default Exchange

    * param2:routingKey,消息的路由Key,是由于Exchange(交换机)将消息发送到指定的消息队列

    * param3:消息包含的属性(通常不需要)

    * param4:消息体(需要转成字节数组)

    *

    * 这里没有定义交换机,消息将发送给默认交换机,每个队列也会绑定那个默认的交换机,但是不能是不绑定或解除绑定

    * */

            channel.basicPublish("","zhengxixi",null,data.getBytes());

            System.out.println("向RabbitMQ上传消息:"+data);

  13.发送完之后就把资源都关闭了,不关闭的话会一直在这里浪费资源----------                  if (channel!=null)

            {

                channel.close();

            }

            if(connection!=null)

            {

                connection.close();

            }

---------------------------------------------------------

                       RabbitMQ提供方上传消息流程

1. 创建连接工厂-----------------------------------------

 ConnectionFactory connectionFactory = new ConnectionFactory();

2.设置RabbitMQ安装的服务器的地址---------------------

connectionFactory.setHost("192.168.80.3");

3.设置RabbitMQ的端口号---------------------------

connectionFactory.setPort(5672);

4.设置登录用户和密码--------------------------------------

connectionFactory.setUsername("admin");

connectionFactory.setPassword("admin");

5.设置指定虚拟机:/为默认------------------------------  

  connectionFactory.setVirtualHost("/");

6.创建与RabbitMQ服务的TCP链接------------------------------------

connection = connectionFactory.newConnection();

7.创建于Exchange的通道,每个连接可以创建多个通道,每个通道代表一个会话任务---------------------------------------------------------

   channel = connection.createChannel();

8./*-------------------------------------------------

  * 声明队列:如果RabbitMQ中没有此队列将自动创建

  * param1:队列的名称

  * param2:是否持久化(rabbit重启后,该队列是否还存在)

  * param3:队列是否独占此链接(其他队列不能使用此链接)

  * param4:队列不再使用时是否自动删除此队列

  * param5:队列参数(通常不需要)

  * */

  channel.queueDeclare("zhengxixi", true, false, false, null);

9.实现消费的方法------------------------------------------

  DefaultConsumer defaultConsumer = new DefaultConsumer(channel)

  {

            /***

            * 当接收到消息后此方法将被调用

            * @param consumerTag 消费者标签,用于标识消费者的,在监听队列时设置channel,basicConsume(可以不设置)

            * @param envelope 信封,通过envelope

            * @param properties 消息属性

            * @param body 消息内容

            * @throws IOException

            */

      @Override

      public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException

      {

              //获取交换机

              String exchange = envelope.getExchange();

              //消息id,MQ在channel中用来标识消息的id,可用于确认消息已接受

              long deliveryTag = envelope.getDeliveryTag();

              //接收到的消息的内容

              String data = new String(body, "UTF-8");

              System.out.println("从客户端获取到数据为:"+data);

      }

    };

10.调用实现消费的方法获取数据(监听队列)-------------------------

/***

    * 参数:String queue , boolean autoAck , Consumer callback

    * 参数明细:

    * 1:queue:队列名称

    * 2.autoAck:自动回复,当消费者接收到消息后要告诉MQ消息已接收,

    *  如果将此参数设置为true表示会自动回复MQ,如果设置为false要通过编程实现回复

    * 3.callback:消费方法,当消费者接收到消息,需要执行的方法

    */

    channel.basicConsume("zhengxixi", true, defaultConsumer);