RABBITMQ学习系列教程

RabbitMQ学习系列教程三:快速入门

快速入门:消息的生产者和消费者生产者的代码步骤:1:获取到连接的工厂ConnectionFactory2:从工厂中获取到一个连接:connection3:重建一个数据通信的通道,可以发送和接收消息对象:channel4:通过channel发送消息5:关闭流代码编写:public class Procuder { publi

快速入门:消息的生产者和消费者

生产者的代码步骤:

1:获取到连接的工厂 ConnectionFactory

2:从工厂中获取到一个连接:connection

3:重建一个数据通信的通道,可以发送和接收消息对象:channel

4:通过channel发送消息

5:关闭流

代码编写:

public class Procuder {

    public static void main(String[] args) throws IOException, TimeoutException {
        //1:创建一个connectioFactory工厂对象,并进行配置
        ConnectionFactory connectionFactory = new ConnectionFactory();
            //设置ip 端口 vhost等
        connectionFactory.setHost("192.168.31.128");
        connectionFactory.setPort(5672);
        connectionFactory.setVirtualHost("/");
        //2:通过工厂对象获取到connection对象
        Connection connection = connectionFactory.newConnection();

        //3:通过connection对象获取到一个消息通信的通道 channel
        Channel channel = connection.createChannel();
        // 4:通过channel发送数据
        /**
         * 参数说明:
         * exchange: 数据路由 routingKey: props: 消息描述body:消息体。字节数组
         */

     

原创不易,完成人机校验,阅读全文

相关推荐