RabbitMQ官方入门案例

RabbitMQ官方入门案例

官方提供7个案例

​​RabbitMQ官方链接​​

helloworld-demo

导入依赖

导入依赖

com.rabbitmq amqp-client 5.12.0

官方实例

​​实例地址​​

消息生产者

setPort(5672)

如图需要开启5672端口

消息接收

/** * @PackageName : com.rzk.recv * @FileName : Recv * @Description : 接收 * @Author : rzk * @CreateTime : 23/6/2021 上午12:22 * @Version : 1.0.0 */public class Recv { private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws Exception { //创建工厂 ConnectionFactory factory = new ConnectionFactory(); factory.setHost("ip"); factory.setUsername("yeb"); factory.setVirtualHost("/yeb"); factory.setPassword("yeb"); factory.setPort(5672); //连接工厂创建连接 Connection connection = factory.newConnection(); //创建信道 Channel channel = connection.createChannel(); //绑定队列 channel.queueDeclare(QUEUE_NAME, false, false, false, null); System.out.println(" [*] Waiting for messages. To exit press CTRL+C"); DeliverCallback deliverCallback = (consumerTag, delivery) -> { String message = new String(delivery.getBody(), "UTF-8"); System.out.println(" [x] Received '" + message + "'"); }; //监听队列消费消息 channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> { }); }}

启动发送消息方法

然后去RabbitMQ客户端yeb用户登录 查看是否有一个消息

启动接收消息方法

查看控制台和客户端消息有没有变为0变为0就是接收成功

到达这一步简单的例子使用成功

可以选择channel通道看看连接是否在线

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。