一、RabbitMQ初使用（Consumer）

RabbieMQ使用过程中的小问题

在rabbitmq的使用过程中，记录一些自己的使用问题
因为在我当前的项目中，我只是一个独立的分析jar，各位看官按自己需求修改

首先是pom引用：

 <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.1.2</version>
</dependency>

初始化Consumer

    static   void  initConsumer(String recvipAddress,int recvport) throws IOException  {Address[] addresses = new Address[] {new Address(recvipAddress, recvport)};ConnectionFactory factory = new ConnectionFactory();factory.setUsername(RabbitConfig.UserName);factory.setPassword(RabbitConfig.PassWord);try {Connection connection = factory.newConnection(addresses);   // 创建连接channel = connection.createChannel();   // 创建信道channel.basicQos(1); // 设置客户端最多接受未被ack的消息的个数     }catch (Exception e) {e.printStackTrace();}}

初始化完成后，可以调用接收方法，接收数据

static   void recvMessage(String queue) throws IOException {Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body) throws IOException {//System.out.println("Recv message=" +new String(body));String Message =new String(body);dataProcessing(Message); //该方法是接收到消息后，具体的处理方法try {TimeUnit.SECONDS.sleep(1);} catch (InterruptedException e) {e.printStackTrace();}channel.basicAck(envelope.getDeliveryTag(), false);}};channel.basicConsume(queue, consumer);}

具体实现方法

  static  void  dataProcessing(String body) {//具体实现
}

一、RabbitMQ初使用（Consumer）相关推荐

centos安装rabbitmq_【SpringBoot MQ系列教程】RabbitMq 初体验
SpringBoot 系列教程之 RabbitMq 初体验mp.weixin.qq.com mq 在异步解耦削峰的优势非常突出,现在很多的项目都会用到,掌握 mq 的知识点,了解如何顺畅的使用 mq ...
手把手教你SpringBoot+RabbitMQ实现手动Consumer Ack
你知道的越多,不知道的就越多,业余的像一棵小草! 你来,我们一起精进!你不来,我和你的竞争对手一起精进! 编辑:业余草 blog.csdn.net/LoveLacie 推荐:https://www.x ...
Spring Cloud Bus之RabbitMQ初窥
和Spring Cloud Config一样,我们接下来要聊的Spring Cloud Bus也是微服务架构系统中的必备组件.Spring Cloud Bus可以将分布式系统的节点与轻量级消息代理链接 ...
Java开发 - 消息队列之RabbitMQ初体验
目录前言 RabbitMQ 什么是RabbitMQ RabbitMQ特点安装启动 RabbitMQ和Kafka的消息收发区别 RabbitMQ使用案例添加依赖添加配置创建RabbitMQ配置 ...
RabbitMQ的consumer预取(prefetch)行为
RabbitMQ的consumer可以在Pull模式处理消息, 也可以在push模式下处理消息.无论是pull模式还是在push模式, 都可以设置消息确认方式:自动确认(autoAck为true),或 ...
RabbitMQ入门用法及消息模型案例
消息中间件之RabbitMQ 核心概念 JMS(JAVA Message Service,java消息服务)API是一个消息服务的标准或者说是规范,允许应用程序组件基于JavaEE平台创建.发送. ...
超详细的RabbitMQ入门
转载:超详细的RabbitMQ入门,看这篇就够了!-阿里云开发者社区思维导图一.什么是消息队列消息指的是两个应用间传递的数据.数据的类型有很多种形式,可能只包含文本字符串,也可能包含嵌入对象. ...
一个winform带你玩转rabbitMQ
源码已放出 https://github.com/dubing/MaoyaRabbit 本章分3部分一.安装部署初探二.进阶三.api相关安装部署初探先上图一. 安装部署下载 rab ...
RabbitMQ 高频考点
1 MQ 存在的意义消息中间件一般主要用来做异步处理.应用解耦.流量削峰.日志处理等方面. 1.1 异步处理一个用户登陆网址注册,然后系统发短信跟邮件告知注册成功,一般有三种解决方法. 串行方 ...

一、RabbitMQ初使用（Consumer）

一、RabbitMQ初使用（Consumer）相关推荐

最新文章

热门文章