南阳专业做网站,双线网站,深圳做网站可用乐云seo十年,住房和城乡建设部门户一、前言
开发时经常与其它系统用rabbitmq对接#xff0c;当需要自测时#xff0c;还是自己写rabbitmq生产者、消费者自测方便些。
下面总结下不用框架、使用java编写简易rabbitmq的方法。
二、代码
1.导入jar包
(1)如果是maven#xff0c;那就用
dependency当需要自测时还是自己写rabbitmq生产者、消费者自测方便些。
下面总结下不用框架、使用java编写简易rabbitmq的方法。
二、代码
1.导入jar包
(1)如果是maven那就用
dependencygroupIdcom.rabbitmq/groupIdartifactIdamqp-client/artifactIdversion3.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_nameq.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)消费者启动后一直开启除非手动关闭项目运行
