标签：connectionFactory 安装 rabbitmq rabbitmqctl RabbitMQ 使用 docker com

RabbitMQ安装与使用

• • RabbitMQ简介
  • RabbitMQ安装（Docker方式）
  • • 常用操作命令
  • RabbitMQ快速入门

RabbitMQ简介

RabbitMQ是—个开源的消息代理和队列服务器，用来通过普通协议 在完全不同的应用之间共享数据，RabbitMQ是使用Erlang语言来编写 的，并且RabbitMQ是基于AMQP协议的。

RabbitMQ安装（Docker方式）

注意获取镜像的时候要获取management版本的，不要获取last版本的，management版本的才带有管理界面

1.查询镜像

docker search rabbitmq:management
2.获取镜像

docker pull rabbitmq:management

3.运行镜像

方式一：默认guest用户，密码也是guest（推荐使用）

docker run -d -p 5672:5672 -p 15672:15672 --name rabbitmq rabbitmq:management

方式二：设置用户名和密码

docker run -d \

 --name my-rabbitmq \

 -p 5672:5672 -p 15672:15672 \

 -v /data:/var/lib/rabbitmq \

 --hostname my-rabbitmq-host \

 -e RABBITMQ_DEFAULT_VHOST=my_vhost \

 -e RABBITMQ_DEFAULT_USER=admin \

 -e RABBITMQ_DEFAULT_PASS=admin \

 --restart=always \

 rabbitmq:management

参数说明：
-d：后台运行容器

-name：指定容器名

-p：指定服务运行的端口（5672：应用访问端口；15672：控制台Web端口号）

-v：映射目录或文件，启动了一个数据卷容器，数据卷路径为：/var/lib/rabbitmq，再将此数据卷映射到住宿主机的/data目录

–hostname：主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，默认为主机名）

-e：指定环境变量；（RABBITMQ_DEFAULT_VHOST：默认虚拟机名；RABBITMQ_DEFAULT_USER：默认的用户名；RABBITMQ_DEFAULT_PASS：默认用户名的密码）

–restart=always：当Docker重启时，容器能自动启动

rabbitmq:management：镜像名

注1：RABBITMQ_DEFAULT_VHOST=my_vhost，my_vhost名字请记好，在之后的编程中要用到,

如果启动时没指定，默认值为/

4.进入RabbitMQ管理平台进行相关操作

注1：容器启动后，可以通过docker logs 窗口ID/容器名字 查看日志

docker logs my-rabbitmq

注2：停止并删除所有容器

docker stop $(docker ps -aq) && docker rm $(docker ps -aq)

常用操作命令

命令行与管控台-基础操作

rabbitmqctl stop_app：关闭应用

rabbitmqctl start_app：启动应用

rabbitmqctl status：节点状态

rabbitmqctl add_user username password：添加用户

rabbitmqctl list_users：列出所有用户

rabbitmqctl delete_user username：删除用户

rabbitmqctl clear_permissions -p vhostpath username：清除用户权限

rabbitmqctl list_user_permissions username：列出用户权限

rabbitmqctl change_password username newpassword：修改密码

rabbitmqctl set_permissions -p vhostpath username “.” “.” “.*”

rabbitmqctl add_vhost vhostpath：创建虚拟主机

rabbitmqctl list_vhosts：列出所有虚拟主机

rabbitmqctl list_permissions -p vhostpath：列出虚拟主机上所有权限

rabbitmqctl delete_vhost vhostpath：删除虚拟主机

rabbitmqctl list_queues：查看所有队列信息

rabbitmqctl -p vhostpath purge_queue blue：清除队列里的消息

命令行与管控台-高级操作

rabbitmqctl reset：移除所有数据，要在rabbitmqctl stop_app之后使用

rabbitmqctl join_cluster [–ram]：组成集群命令

rabbitmqctl cluster_status：查看集群状态

rabbitmqctl change_cluster_node_type disc | ram：修改集群节点的存储形式

rabbitmqctl forget_cluster_node {–offline} 忘记节点 （摘除节点）

rabbitmqctl rename_cluster_node oldnode1 newnode1 [oldnode2] [newnode2…] （修改节点名称）

RabbitMQ快速入门

消息生产与消费
ConnectionFactory：获取连接工厂

Connection：一个链接

Channel：数据通信通道，课发送和接收消息

Queue：具体的消息存储队列

Producer & Consumer：生产和消费者

1、创建一个springboot项目： rabbitmq-api

2、导入pom依赖

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>3.6.5</version>
</dependency>

3、消费端代码

package com.tanjie.rabbitmqapi.quickstart;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;


public class Consumer {
    public static void main(String[] args) throws Exception {

        //1 创建一个ConnectionFactory, 并进行配置
        ConnectionFactory connectionFactory = new ConnectionFactory();
        connectionFactory.setHost("192.168.253.129");
        connectionFactory.setPort(5672);
        connectionFactory.setVirtualHost("/");

        //2 通过连接工厂创建连接
        Connection connection = connectionFactory.newConnection();

        //3 通过connection创建一个Channel
        Channel channel = connection.createChannel();

        //4 声明（创建）一个队列
        String queueName = "test001";
//        参数：队列名称、持久化与否、独占与否、无消息队列是否自动删除、消息参数
//        queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
        channel.queueDeclare(queueName, true, false, false, null);

        //5 创建消费者
        QueueingConsumer queueingConsumer = new QueueingConsumer(channel);

        //6 设置Channel
//         参数：队列名称、自动签收、消费者回调
//        basicConsume(String queue, boolean autoAck, Consumer callback)
        channel.basicConsume(queueName, true, queueingConsumer);

        while(true){
            //7 获取消息（Delivery：传送）
            QueueingConsumer.Delivery delivery = queueingConsumer.nextDelivery();
            String msg = new String(delivery.getBody());
            System.err.println("消费端: " + msg);
            //Envelope envelope = delivery.getEnvelope();
        }
    }
}

4、生产端代码

package com.tanjie.rabbitmqapi.quickstart;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;


public class Procuder {
    public static void main(String[] args) throws Exception {
        //1 创建一个ConnectionFactory, 并进行配置
        ConnectionFactory connectionFactory = new ConnectionFactory();
        connectionFactory.setHost("192.168.253.129");
        connectionFactory.setPort(5672);
        connectionFactory.setVirtualHost("/");

        //2 通过连接工厂创建连接
        Connection connection = connectionFactory.newConnection();

        //3 通过connection创建一个Channel
        Channel channel = connection.createChannel();

        //4 通过Channel发送数据
        for(int i=0; i < 5; i++){
            String msg = "Hello RabbitMQ!";
            //1 exchange   2 routingKey
            channel.basicPublish("", "test001", null, msg.getBytes());
        }

        //5 记得要关闭相关的连接
        channel.close();
        connection.close();
    }
}

启动生产端 Procuder效果

启动消费端 Consumer

标签：connectionFactory,安装,rabbitmq,rabbitmqctl,RabbitMQ,使用,docker,com
来源： https://blog.csdn.net/m0_47252566/article/details/111959161

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。