rabbitmq使用总结

1、进入rabbitmq的sbin目录，进入CMD

2、输入./rabbitmq-plugins enable rabbitmq_management启用管理服务。

3、输入./rabbitmqctl start_app启动服务。

查看是否启动成功

1、浏览器访问http://localhost:15672/

下载erlang

地址如下：

http://erlang.org/download/otp_win64_20.3.exe

找到 otp_win64_20.3.exe，以管理员方式运行此文件，安装。

erlang安装完成需要配置erlang环境变量：

这两个都加入到系统盘中去

ERLANG_HOME=D:\Program Files\erl9.3

在path中添加%ERLANG_HOME%\bin;

2）安装RabbitMQ

https://github.com/rabbitmq/rabbitmq-server/releases/tag/v3.7.3

找到 rabbitmq-server-3.7.3.exe，以管理员方式运行此文件，安装。

 普通java 项目的依赖
 <dependency>
 ? ? ? ? ? ?<groupId>com.rabbitmq</groupId>
 ? ? ? ? ? ?<artifactId>amqp-client</artifactId>
 ? ? ? ? ? ?<version>4.0.3</version>
 ? ? ? ?</dependency>

TOPIC 模式 也就是路由模式 ?
p ?提供了准确的路径
c ?提供了大概得路径 ? 来消费数据

Confirm 确认消息 用在 p -> ex 上面的 先连同 以后在上传数据，两上去发送失败就会触发这个机制

 channel.confirmSelect(); // 开启监听 可能不止一个管道
 
 channel.addConfirmListener(new ConfirmListener() {
 ? ? ? ? ? ?public void handleAck(long l, boolean b) throws IOException {
 ? ? ? ? ? ? ? ?System.out.println(l);
 ? ? ? ? ? ? ? ?System.out.println(b);
 ? ? ? ? ? ? ? ?System.out.println("确认获取...");
 ? ? ? ? ?  }
?
 ? ? ? ? ? ?public void handleNack(long l, boolean b) throws IOException {
 ? ? ? ? ? ? ? ?System.out.println(l);
 ? ? ? ? ? ? ? ?System.out.println(b);
 ? ? ? ? ? ? ? ?System.out.println("未获取...");
 ? ? ? ? ?  }
 ? ? ?  });

retrun 消息机制

 ? // 执行失败的时候添加的返回数据  成的时候什么都不会 这里是它自己的bug
 ? ? ? ?channel.addReturnListener(new ReturnListener() {
 ? ? ? ? ? ?public void handleReturn(int i, String s, String s1, String s2, AMQP.BasicProperties basicProperties, byte[] bytes) throws IOException {
 ? ? ? ? ? ? ? ?String str = new String(bytes, "UTF-8");
 ? ? ? ? ? ? ? ?System.out.println("没有路由成功的数:" + str);
 ? ? ? ? ?  }
 ? ? ?  });

消费端的限流

channel.basicQos(2); // 每次消费两条数据  限流策略关键代码
// 开启acKnowledge验证数据 读出数据单未消费掉
channel.basicConsume("myqosqu", false, consumer);

消费端的ACK与重回队列 （消费端）

// 手动消费 
channel.basicAck(envelope.getDeliveryTag(),false);
 ?// 两个参数 获取每一条消费的对象id  不配量处理
/
// 手动不消费  也不返回队列（false） true 是返回队列那就死循环了，一直在处理这条数据
 channel.basicNack(envelope.getDeliveryTag(),false,true);

有效时间 (p)

AMQP.BasicProperties properties = new AMQP.BasicProperties()
 ? ? ? ? ? ? ?  .builder()
 ? ? ? ? ? ? ?  .deliveryMode(2)// 设置消息是否持久化，1： 非持久化 2：持久化
 ? ? ? ? ? ? ?  .contentEncoding("UTF-8")
 ? ? ? ? ? ? ?  .expiration("10000")
 ? ? ? ? ? ? ?  .build();
// p 端的数据 第三个参数来设置有效时间
hannel.basicPublish("myoneEx", "myoneAs", properties, smsMsg.getBytes());

死信队列

 ?Map<String, Object> param = new HashMap<String, Object>(); //创建一个死信队列 
 ? ? ? ?param.put("x-dead-letter-exchange", "mytwoEx");
 ? 
 ? ? ? ?channel.exchangeDeclare("myoneEx", BuiltinExchangeType.DIRECT);
// 如果出现问题就放到第二交换机上面去（在队列上设置属性的）
 ? ? ? ?channel.queueDeclare("myoneQu", true, false, false, param);

---

springboot 的使用

 -- 相关依赖
 <dependency>
 ? ? ? ? ? ?<groupId>org.springframework.boot</groupId>
 ? ? ? ? ? ?<artifactId>spring-boot-starter-amqp</artifactId>
 ?</dependency>

这里是springboot一些注解，防止自己忘记，在此查阅了一些资料

@Bean不仅可以作用在方法上，也可以作用在注解类型上，在运行时提供注册。
?
value：name属性的别名，在不需要其他属性时使用，也就是说value 就是默认值
name：此bean 的名称，或多个名称，主要的bean的名称加别名。如果未指定，则bean的名称是带注解方法的名称。如果指定了，方法的名称就会忽略，如果没有其他属性声明的话，bean的名称和别名可能通过value属性配置
autowire ：此注解的方法表示自动装配的类型，返回一个Autowire类型的枚举，我们来看一下Autowire枚举类型的概念

当使用在类上的时候，如下代码，@Qualifier注解里面填写的值就是当前类注入到IOC容器的bean的唯一标识（id），再使用到该Bean的地方就可以直接根据唯一标识（id）从IOC容器中获取了

当使用在属性上的时候，如下代码，@Qualifier 和 @Autowired结合使用可以通过唯一Bean的id实现自动装配，因为单独的@Autowired注解实现自动装配是按照类型优先原则的，一旦IOC容器中出现了两个类型一样的Bean，@Autowired注解就会无法辨别用那个，即而报错，但是当我们加上 @Qualifier(value = "Bean的id") 的时候就可以直接通过Bean的唯一标识（id）进行装配了。

@RabbitListener注解既可以加在类上，也可以加在方法上，其作用有所不同。

正如上面讲的，当@RabbitListener注解加在类上时，表示该类是一个RabbitMQ消息监听器容器，可以包含多个带有@RabbitHandler注解的方法，用于处理不同类型的消息。例如：

@RabbitListener(queues = MQConfig.PAYQUEUE)
public class MQListener{
     @RabbitHandler // 这里处理多个类型的数据
 ? ? public void revicePaySuccess(String orderNo){
 ? ? 
 ? ? }
}

因此，@RabbitListener注解加在类上时，表示该类是一个消息监听器容器，可以包含多个处理不同类型消息的方法；而加在方法上时，表示该方法是一个消息监听器，只用于处理特定类型的消息。