Java编写简易rabbitmq生产者与消费者的代码

目录

• 一、前言
• 二、代码
• 1.导入jar包
• 2.生产者代码
• 3.消费者代码

一、前言

开发时经常与其它系统用rabbitmq对接，当需要自测时，还是自己写rabbitmq生产者、消费者自测方便些。

下面总结下不用框架、使用Java编写简易rabbitmq的方法。

二、代码

1.导入jar包

(1)如果是maven，那就用

<dependency>
		    <grou编程客栈pId>jscom.rabbitmq</groupId>
		    <artifactId>amqp-client</artifactId>
		    <version>3.3.4</version>
		</dependency>

(2)如果没用maven，那就找一个amqp-client-3.3.4.jar文件，然后引入项目

2.生产者代码

package RABBIT_MQ;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class RabbitMQSender {
    //交换机
    private final static String exchange_name = "x.mySys.test";
    //路由键
    private final static String route_key = "topmess";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定义一个链接工厂
 编程客栈       ConnectionFactory connectionFactory = new ConnectionFactory();
        //设置服务地址
        connectionFactory .setHost("10.123.123.123");
        //设定端口
        connectionFactory .setPort(5673);
        //设定用户名
        connectionFactory .setUsername("myuser");
        //设定密码
        connectionFactory .setPassword("mypass");
        //设定虚拟机
        connectionFactory .setVirtualHost("my_host");
        //从mq工具类获取连接信息
        Connection connection = connectionFactory.newConnection();
        //获取一个通道
        Channel channel = connection.createChannel();
        String message = "Hello World!";
        channel.basicPublish(exchange_name, route_key, null, message.getBytes());
        System.out.println("运行完毕，已发送消息【" + message + "】");
        channel.closehttp://www.devze.com();
        connection.close();
    }
}

说明：

(1)其中的配置，按照自己的rabbitmq配置更改

(2)生产者配置了交换机名与路由键

3.消费者代码

package RABBIT_MQ;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
public class RabbitMQReceiver {
    private static String queue_name="q.mySys.test";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定义一个链接工厂
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //设置服务地址
        connectionFactory .setHost("10.123.123.123");
        //设定端口
        connectionFactory .setPort(5673);
        //设定用户名
        connectionFactory .setUsername("myuser");
        //设定密码
        connectionFactory .setPassword("mypass");
        //设定虚拟机
        connectionFactory .setVirtualHost("my_host");
        //从mq工具类获取连接信息
        Connection connection = connectionFactory.newConnection();
        //获取一个通道
        Channel channel = connection.createChannel();
        //监听该队列，false代表手动确认
        channel.basicConsume(queue_name,false,new DefaultConsumer(channel){
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties basicProperties, byte[] body) throws IOException{
                System.out.println("接收到的消息："+ new String(body,"UTF-8"));
            }
        });
        System.out.println("运行完毕，等待mq接收消息");
    }
}

说明：

(1)其中的配置，按照自己的rabbitmq配置更改

(2)消费者配置了监听队列

(3)消费者启动后一直开启，除非手动关闭项目运行

到此这篇关于Java编写简易rabandroidbitmq生产者与消费者的文章就介绍到这了,更多相关Java rabbitmq生产者与消费者内容请搜索编程客栈(www.devze.com)以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程客栈(www.devze.com)！