包含标签 RabbitMQ 的文章

RabbitMQ connection channel 的关系

Rabbit java client 发送消息代码如下 1 2 3 4 5 6 7 8 Connection connection = connectionFactory.newConnection(); Channel channel = connection.createChannel(); AMQP.BasicProperties basicProperties = new AMQP.BasicProperties().builder() .messageId(UUID.randomUUID().toString()) .build(); channel.basicPublish("biz","dev.hello",false,basicProperties,"Hello World".getBytes()); channel.close(); connection.close(); 对于 AMQP 0-9-1 网络连接,一个客户端会与 Broker 建立一个 Tcp 长连接(Connec……

阅读全文

AMQ Model总结

前言 最近在写公司的消息队列组件,因为使用的是 RabbitMQ,其实现的规范是基于 AMQP-0-9-1 ,所以抽时间把官方的规范过了一遍,整理出主要的内容,记录于……

阅读全文