RabbitMQ生产者代码

public class Producer {// 队列名称public static  final String QUEUE_NAME="hello";// 发消息public static void main(String[] args) throws IOException, TimeoutException {// 创建一个连接工厂ConnectionFactory factory = new ConnectionFactory();// 工厂IP连接RabbitMQ的队列factory.setHost("192.168.163.128");// 用户名factory.setUsername("admin");// 密码factory.setPassword("123");factory.setPort(5672);// 创建连接Connection connection = factory.newConnection();// 获取信道Channel channel = connection.createChannel();/** 生成一个队列* 参数1：队列名称* 参数2：队列里面的消息是否持久化，默认情况下，消息存储在内存中* 参数3：该队列是否只供一个消费者进行消费，是否进行消费共享，true可以多个消费者消费，*        false只能一个消费者消费* 参数4：是否自动删除：最后一个消费者断开连接之后，该队列是否自动删除，true则自动删除，*        false不自动删除* 参数5：其他参数* */channel.queueDeclare(QUEUE_NAME,false,false,false,null);// 发消息String message = "hello world";/** 发送一个消息* 参数1：发送到哪个交换机* 参数2：路由的key值是那个，本次是队列的名称* 参数3：其他参数信息* 参数4：发送消息的消息体* */channel.basicPublish("",QUEUE_NAME,null,message.getBytes(StandardCharsets.UTF_8));System.out.println("消息发送完毕！");}
}

注意：如果报connection error，考虑是端口号没有开放的问题。连接服务，请求的端口号是5672，而可视化工具服务，请求的是15672，因此需要开启5672跟15672两个端口，测试连接成功！

RabbitMQ生产者代码相关推荐

RabbitMq(八) SpringBoot整合RabbitMQ 生产者代码实现
在本章中我们将创建RabbitMQ的生产者工程,并实现生产者端代码实现. springboot整合RabbitMQ生产者工程步骤如下: 创建maven工程引入springboot及RabbitMQ依 ...
rabbitmq怎样确认是否已经消费了消息_【朝夕专刊】RabbitMQ生产者/消费者消息确认...
欢迎大家阅读<朝夕Net社区技术专刊> 我们致力于.NetCore的推广和落地,为更好的帮助大家学习,方便分享干货,特创此刊!很高兴你能成为忠实读者,文末福利不要错过哦! 上篇文章介绍了R ...
（需求实战_进阶_02）SSM集成RabbitMQ 关键代码讲解、开发、测试
接上一篇:(企业内部需求实战_进阶_01)SSM集成RabbitMQ 关键代码讲解.开发.测试 https://gblfy.blog.csdn.net/article/details/10419730 ...
（需求实战_进阶_01）SSM集成RabbitMQ 关键代码讲解、开发、测试
背景: 为了减轻服务器的压力,现在原有项目的基础上集成消息队列来异步处理消息! 此项目是企业真实需求,项目的代码属于线上生产代码,直接用于生产即可! 此项目采用MQ发送消息模式为:路由模式,如果对Ra ...
rabbitmq 生产者和消费者
生产者下面展示一些内联代码片. import java.util.Date; import java.util.HashMap; import java.util.Map;import com.d ...
Go 学习笔记（57）— Go 第三方库之 amqp （RabbitMQ 生产者、消费者整个流程）
1. 安装 rabbitmq 的 golang 包 golang 可使用库 github.com/streadway/amqp 操作 rabbitmq .使用下面命令安装 RabbitMQ . go ...
PHP 连接 Rabbitmq 实例代码（亲测通过）
接下来我们用 php 连接 rabbitmq 玩一玩. 还没有安装 rabbitmq ,请参考 Rabbitmq 安装还没有安装 PHP 的 AMQP 扩展,参考 PHP AMQP 扩展安装一些概 ...
springboot集成rabbitMQ安装+代码
环境安装本机电脑是mac,所以直接在终端下(无论在哪个目录下都不影响)输入 brew install erlang,先装erlang,不然rabbitmq装了跑不了,接下来就是等待的时刻.... 装 ...
rabbitmq java代码_RabbitMQ java 原生代码
rabbitMQ 的交换器有四种类型:direct.fanout.topic.headers 以下是具体的代码: direct:路由键只能全部匹配,才能进入到指定队列中.其他使用 direct生产者 ...

RabbitMQ生产者代码

RabbitMQ生产者代码相关推荐

最新文章

热门文章