RabbitMQ—Android客户端

存储架构 简书 (源链)

工作原理

RabbitMQ-中文文档

RabbitMQ-官网

上面的网站详细的描述了整个框架。建议没接触过RabbitMQ的同学先看看。了解原理后,就直接看下面的代码吧。

生产者

由于后台缘故,这里不需要exchange。想要看完整的流程的同学可以去看这篇文章。

注意要在子线程中运行

ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(HOST);//ip地址
        factory.setPort(PORT);//端口号
        factory.setUsername("test");
        factory.setPassword("test");
        //创建一个新连接
        Connection connection = factory.newConnection();
        //创建一个通道
        Channel channel = connection.createChannel();
        //声明一个队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        //发送消息
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
        //消息发送完成后,需要关闭通道和连接
        channel.close();
        connection.close();

消费者

ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(HOST);
        factory.setPort(PORT);
        factory.setUsername("test");
        factory.setPassword("test");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        //声明一个队列
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                String message = new String(body, "UTF-8");
                System.out.println("RecvLogsTopic1 [x] Received '" + envelope.getRoutingKey() + "':'" + message + "'");
            }
        };
        channel.basicConsume(QUEUE_NAME, true, consumer);

您可能感兴趣的

通过实例理解 RabbitMQ 的基本概念 先说下自己开发的实例。 最近在使用 Spring Cloud Config 做分布式配置中心(基于 SVN/Git), 当所有服务启动后,SVN/Git 中的配置文件更改后,客户端服务读取的还是旧的配置,并不能实时读取(配置信息会缓存在客户端) ,Spring Boot 提供了一种方...
Kafka VS RabbitMQ | Difference between RabbitMQ &a... 1. Objective It is very frequent question that, what are the differences between RabbitMQ and Kafka. So, in this article “Kafka VS RabbitMQ”...
消息中间件选型分析:从Kafka与RabbitMQ的对比看全局... 一、前言 消息队列中间件(简称消息中间件)是指利用高效可靠的消息传递机制进行与平台无关的数据交流,并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型,它可以在分布式环境下提供应用解耦、弹性伸缩、冗余存储、流量削峰、异步通信、数据同步等等功能,其作为分布式系统架构中的一个重...
CentOs7.3 搭建 RabbitMQ 3.6 单机多实例服务... RabbitMQ简介 RabbitMQ是一个开源的AMQP实现,服务器端用Erlang语言编写,支持多种客户端,如:Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等,支持AJAX。用于在分布式系统中存储转发消息,在易用性、扩展性、高...
Spring Boot与RabbitMQ结合 编辑推荐: 本文来源简书,介绍了一种只需在服务端进行授权即可,无需在前端添加额外设置,比传统的JSONP跨域更安全和便捷的方式CORS。 背景 何为延迟队列? 顾名思义,延迟队列就是进入该队列的消息会被延迟消...
简书责编内容来自:简书 (源链) | 更多关于

阅读提示:酷辣虫无法对本内容的真实性提供任何保证,请自行验证并承担相关的风险与后果!
本站遵循[CC BY-NC-SA 4.0]。如您有版权、意见投诉等问题,请通过eMail联系我们处理。
酷辣虫 » RabbitMQ—Android客户端



专业 x 专注 x 聚合 x 分享 CC BY-NC-SA 4.0

使用声明 | 英豪名录