当前位置:   article > 正文

springboot集成rabbitMQ_failed to add match 'rabbitmq-server': invalid arg

failed to add match 'rabbitmq-server': invalid argument

首先你要自己安装一个RabbitMQ,这里是安装包

由于RabbitMQ是用Erlang语言编写的,因此需要先安装Erlang。

https://www.rabbitmq.com/install-windows.html

https://www.erlang.org/downloads

下面进入正题

首先是pom文件

  1. <!-- amqp -->
  2. <dependency>
  3. <groupId>org.springframework.boot</groupId>
  4. <artifactId>spring-boot-starter-amqp</artifactId>
  5. </dependency>

rabbit的配置类,这个类里面可以配置messageconverter等。这里可以根据自己的需要补充

  1. package com.wc.www.ScBus.mq;
  2. import org.springframework.amqp.core.Queue;
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. /**默认支持SimpleMessageConverter,
  6. * java.lang.IllegalArgumentException: SimpleMessageConverter only supports String, byte[]
  7. * and Serializable payloads, received: com.wc.www.ScBus.entity.Teacher
  8. * @author Administrator
  9. *
  10. */
  11. @Configuration
  12. public class RabbitConfig {
  13. @Bean
  14. public Queue helloQueue() {
  15. return new Queue("helloMQ"); //配置一个名称为"hello"的Queue队列
  16. }
  17. /*
  18. * @Bean public RabbitListenerContainerFactory<?>
  19. * rabbitListenerContainerFactory(ConnectionFactory connectionFactory){
  20. * SimpleRabbitListenerContainerFactory factory = new
  21. * SimpleRabbitListenerContainerFactory();
  22. * factory.setConnectionFactory(connectionFactory);
  23. * factory.setMessageConverter(new Jackson2JsonMessageConverte
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/我家小花儿/article/detail/996844
推荐阅读
相关标签
  

闽ICP备14008679号