1. 创建连接的工具类

*** Created by wzy on 2020/12/3* 用于创建连接的工具类*/
public class ConnectionUtil {public static Connection getConnection() throws Exception{//获取连接ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("192.168.80.128");connectionFactory.setPort(5672);connectionFactory.setUsername("zhaobl");connectionFactory.setPassword("123456");connectionFactory.setVirtualHost("/");return connectionFactory.newConnection();//创建一个新的链接}
}

2.创建消息接收者

/*** Created by wzy on 2020/12/3* 消息接收者*/
public class Recver {private final static String QUEUE = "testhello";public static void main (String[] arsg) throws Exception{//获取连接Connection connection = ConnectionUtil.getConnection();//创建通道Channel channel =connection.createChannel();//声明队列channel.queueDeclare(QUEUE,false,false,false,null);//定义接收者boolean autoAck = false;channel.basicConsume(QUEUE, autoAck, "myConsumerTag",new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {//System.err.println("-----------consume message----------");//System.err.println("consumerTag: " + consumerTag);//System.err.println("envelope: " + envelope);//System.err.println("properties: " + properties);System.err.println("body: " + new String(body));}});}
}

3.创建消息发送者

/*** Created by wzy on 2020/12/3* 消息发送者*/
public class Sender {private final static String QUEUE = "testhello";public static void main (String[] arsg) throws Exception{//获取连接Connection connection = ConnectionUtil.getConnection();//创建通道Channel channel =connection.createChannel();//声明队列,如果队列存在什么都不做，如不存在才创建// 参数1 队列名称// 参数2 是否持久化队列，我们的队列存在于内存中，如果rabbitmq 重启会丢失,如设置为true// 会保存到erlang数据库中// 参数3 是否排外，当连接关闭自动删除队列，如私有其他通道不能访问// 参数4 是否自动删除队列// 参数5 其他参数channel.queueDeclare(QUEUE,false,false,false,null);//发送内容channel.basicPublish("",QUEUE,null,"发送消息".getBytes());//关闭连接channel.close();connection.close();}
}

4.运行控制台输出结果

【夏目鬼鬼分享】rabbitmq消息队列发送于接收相关推荐

使用spring-rabbit测试RabbitMQ消息确认(发送确认,接收确认)
1.首先是rabbitmq的配置文件: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns ...
RabbitMQ学习系列二：.net 环境下 C#代码使用 RabbitMQ 消息队列
上一篇已经讲了Rabbitmq如何在Windows平台安装,不懂请移步:RabbitMQ学习系列一:windows下安装RabbitMQ服务一.理论: .net环境下,C#代码调用RabbitMQ消 ...
rabbitMQ消息队列 – 面板介绍及简单demo
首先rabbit安装好之后,运维会给一个控制面板. 默认账号密码为guest 登入以后可以看到具体界面. 在此鸣谢百度翻译给予的大力支持.. ###写一个简单的demo 编写之前..虽然说可以直接用底 ...
大数据互联网架构阶段 QuartZ定时任务+RabbitMQ消息队列
QuartZ定时任务+RabbitMQ消息队列一 .QuartZ定时任务解决订单系统遗留问题情景分析: 在电商项目中 , 订单生成后 , 数据库商品数量-1 , 但是用户迟迟不进行支付操作 , 这 ...
RabbitMQ消息队列（七）：适用于云计算集群的远程调用(RPC)
在云计算环境中,很多时候需要用它其他机器的计算资源,我们有可能会在接收到Message进行处理时,会把一部分计算任务分配到其他节点来完成.那么,RabbitMQ如何使用RPC呢?在本篇文章中,我们将会 ...
干货：RabbitMQ消息队列基本原理介绍
RabbitMQ 是高级消息队列协议(AMQP)的开源消息代理软件. RabbitMQ 服务器是用 Erlang 语言编写的,消息系统允许软件.应用相互连接和扩展.这些应用可以相互链接起来组成一个更大 ...
使用EasyNetQ组件操作RabbitMQ消息队列服务
RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue)的开源实现,是实现消息队列应用的一个中间件,消息队列中间件是分布式系统中重要的组件,主要解决应用耦合, ...
初探 RabbitMQ 消息队列
初探 RabbitMQ 消息队列 rabbitmq基础概念常见应用场景导入依赖属性配置具体编码定义队列实体类控制器消息消费者主函数测试总结说点什么 SpringBoot 是为了简化 Spring 应用 ...
详解SpringCloud中RabbitMQ消息队列原理及配置，一篇就够！
作者:kosamino cnblogs.com/jing99/p/11679426.html 一.MQ用途 1.同步变异步消息场景:用户下单完成后,发送邮件和短信通知. 运用消息队列之后,用户下单完 ...

【夏目鬼鬼分享】rabbitmq消息队列发送于接收

1. 创建连接的工具类

2.创建消息接收者

3.创建消息发送者

4.运行控制台输出结果

【夏目鬼鬼分享】rabbitmq消息队列发送于接收相关推荐

最新文章

热门文章