1.SpringBoot整合RabbitMQ使用

 

1.引入依赖：

 

        <!--引入与rabbitmq集成的依赖-->

 

        <dependency>

 

            <groupId>org.springframework.boot</groupId>

 

            <artifactId>spring-boot-starter-amqp</artifactId>

 

        </dependency>

 

2.做配置 ：application.yml

 

spring:

 

  application:

 

    name: rabbitmq-springboot

 

  rabbitmq:

 

    host: 192.168.231.141

 

    port: 5672

 

    username: ems

 

    password: 123456

 

    virtual-host: /ems

 

3.hello world

 

@SpringBootTest（classes = RabbitmqSpringbootApplication.class）

 

@RunWith（SpringRunner.class）

 

@ComponentScan（"com.liziyi"）

 

// @EnableRabbit启用@RabbitListener

 

@EnableRabbit

 

public class TestRabbitMQ {

 

    // 注入rabbitTemplate

 

    @Autowired

 

    private RabbitTemplate rabbitTemplate;

 

    // hello world

 

    @Test

 

    public void test（） {

 

        rabbitTemplate.convertAndSend（"hello","hello world"）;

 

    }

 

}

 

// 被工厂扫描道

 

@Component

 

// 消费者（声明队列）

 

@RabbitListener（queuesToDeclare = @Queue（"hello"））

 

public class HelloCustomer {

 

    // 代表通过下面方法取消息

 

    @RabbitHandler

 

    public void receivel（String message） {

 

        System.out.println（"message = " + message）;

 

    }

 

}

 

但是最后执行了。在网页上没有见到新建的队列

 

4.work

 

@SpringBootTest（classes = RabbitmqSpringbootApplication.class）

 

@RunWith（SpringRunner.class）

 

@ComponentScan（"com.liziyi"）

 

// @EnableRabbit启用@RabbitListener

 

@EnableRabbit

 

public class TestRabbitMQ {

 

    // 注入rabbitTemplate

 

    @Autowired

 

    private RabbitTemplate rabbitTemplate;

 

    // work

 

    @Test

 

    public void testWork（） {

 

        for （int i = 0; i < 10; i++） {

 

            rabbitTemplate.convertAndSend（"work","work模型"+i）;

 

        }

 

    }

 

}

 

@Component

 

public class WorkCustomer {

 

    @RabbitListener（queuesToDeclare = @Queue（"work"））

 

    public void receivel（String message） {

 

        System.out.println（"message1 =" +message）;

 

    }

 

    @RabbitListener（queuesToDeclare = @Queue（"work"））

 

    public void receivel2（String message） {

 

        System.out.println（"message2 =" +message）;

 

    }

 

}

 

5.fanout

 

@SpringBootTest（classes = RabbitmqSpringbootApplication.class）

 

@RunWith（SpringRunner.class）

 

@ComponentScan（"com.liziyi"）

 

// @EnableRabbit启用@RabbitListener

 

@EnableRabbit

 

public class TestRabbitMQ {

 

    // 注入rabbitTemplate

 

    @Resource

 

    private RabbitTemplate rabbitTemplate;

 

    // fanout 广播

 

    @Test

 

    public void testFanout（） {

 

        rabbitTemplate.convertAndSend（"logs","","fanout模型"）;

 

    }