rabbitmq基础及进阶

官网地址
rabbitmq下载官网

安装

rpm -ivh erlang-21.3-1.el7.x86_64.rpm # 安装erlang
yum install socat -y # 安装依赖
rpm -ivh rabbitmq-server-3.8.8-1.el7.noarch.rpm # 安装mq

常用命令

添加开机启动 RabbitMQ 服务
chkconfig rabbitmq-server on

/sbin/service rabbitmq-server start # 启动
/sbin/service rabbitmq-server status # 查看状态
/sbin/service rabbitmq-server status # 停止服务
rabbitmq-plugins enable rabbitmq_management # 开启 web 管理插件

用默认账号密码(guest)访问地址：http:/ channel.queueDeclare(QUEUE_NAME,false,false,false,null); //发送消息 String message = "hello world"; channel.basicPublish("",QUEUE_NAME,null,message.getBytes()); } } ps:记得开放端口 5672

public class Consumer {
    public static final String QUEUE_NAME="hello";
    //接收消息
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
         factory.setHost("192.168.1.1");
        //用户名
        factory.setUsername("admin");
        //密码
        factory.setPassword("admin");
        factory.setPort(5672);
        //factory.setVirtualHost("hbsi"); // 虚拟机
        //连接
        Connection connection = factory.newConnection();

        //通道
        Channel channel = connection.createChannel();
        
        com.rabbitmq.client.Consumer consumer = new DefaultConsumer(channel){
            
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                System.out.println("consumerTag："+consumerTag);
                System.out.println("Exchange："+envelope.getExchange());
                System.out.println("RoutingKey："+envelope.getRoutingKey());
                System.out.println("DeliveryTag："+envelope.getDeliveryTag());
                System.out.println("properties："+properties);
                System.out.println("body："+new String(body));
            }
        };
        channel.basicConsume(QUEUE_NAME,true,consumer);
    }
}