您的位置:首页 > 编程语言 > Java开发

JavaClient - RabbitMQ实用教程

2016-12-29 00:00 330 查看
ExchangeType:

发布订阅:Direct

广播:Fanout

主题:Topic

头部信息过滤:Headers

相关配置属性?

name:名称

Durability:持久化标志,如果为true,则表明此exchange是持久化的。

exclusive:排他队列。mq断开连接时,不管是否持久化,都会删除该队列。

Auto-delete:删除标志,当所有队列在完成使用此exchange时,是否删除

Arguments:其他一些属性Map

简单贴些烂代码:

// 创建连接和频道
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.32.129");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();

// 虚拟机、队列、绑定
channel.exchangeDeclare(exchangeName, type, true);// type:ExchangeType
channel.queueDeclare(queueName, true, false, false, null); // 相关属性指这里的
channel.queueBind(queueName, exchangeName, routingKey);

// 生产者 // MessageProperties:是否持久化,持久化协议
channel.basicPublish(getExchangeName(), getRoutingKey(), MessageProperties.MINIMAL_PERSISTENT_BASIC, message.getBytes(Charset.forName("UTF-8")));
// 消费者:
channel.basicConsume(getQueueName(), autoAck, new Consumer(){
# handleDelivery 接收信息后的处理
});

推荐几篇文章:

RabbitMQ与AMQP协议详解:http://www.cnblogs.com/frankyou/p/5283539.html

RabbitMQ几种典型实用场景:http://www.cnblogs.com/luxiaoxun/p/3918054.html

RabbitMQ的三种Exchange,数据持久化,非持久化实例http://blog.csdn.net/lk10207160511/article/details/50334173

rabbitmq_management介绍:http://blog.csdn.net/u013696226/article/details/21530659
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  RabbitMQ Java