Java编写简易rabbitmq生产者与消费者-CSDN博客
阿里云国内75折 回扣 微信号:monov8 |
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6 |
一、前言
开发时经常与其它系统用rabbitmq对接当需要自测时还是自己写rabbitmq生产者、消费者自测方便些。
下面总结下不用框架、使用java编写简易rabbitmq的方法。
二、代码
1.导入jar包
(1)如果是maven那就用
<dependency>
<groupId>com.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.close();
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)消费者启动后一直开启除非手动关闭项目运行
阿里云国内75折 回扣 微信号:monov8 |
阿里云国际,腾讯云国际,低至75折。AWS 93折 免费开户实名账号 代冲值 优惠多多 微信号:monov8 飞机:@monov6 |