1. 新建隊列

2. 新增POM.xml配置文件

    <parent>

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

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

        <version>2.6.0</version>

        <relativePath />

    </parent>

    <dependencies>

        <dependency>

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

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

        </dependency>

        <dependency>

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

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

        </dependency>

        <dependency>

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

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

            <scope>test</scope>

        </dependency>

    </dependencies>

3. 配置application.yml文件

spring:

  rabbitmq:

    host: 127.0.0.1

    username: guest

    password: guest

    virtualHost: /

  profiles:

    active: dev

server:

  port: 8080

4. 編寫application啟動類

@SpringBootApplication

public class BlogCodeApplication {

    public static void main(String[] args) throws Exception {

        SpringApplication.run(BlogCodeApplication.class, args);

    }

}

5. 編寫生產者

@Component

public class RabbitSender {

    private RabbitTemplate rabbitTemplate;

    public RabbitSender(RabbitTemplate rabbitTemplate) {

        this.rabbitTemplate = rabbitTemplate;

    }

    /**

     * 不顯式聲明交換機時并且發送消息不指定交換機，則默認使用Direct，

     * 并且聲明隊列時，不顯式綁定隊列與交換機，則隊列以隊列名為routing-key

     * 綁定到默認的direct交換機，

     * 發送消息不指定交換機時，則將消息發到默認的direct交換機

     */

    public void send() {

        String msg = "Hello World!";

        this.rabbitTemplate.convertAndSend("hello", msg);

        System.out.println("發送消息" + msg + "至隊列hello");

    }

}

6. 編寫測試類并運行

@SpringBootTest

public class RabbitTest {

    @Autowired

    private RabbitSender rabbitSender;

    @Test

    public void testSender() {

        rabbitSender.send();

    }

}

7. 消息已發送至隊列

歡迎關注公眾號算法小生或沈健的技術博客

總結

以上是生活随笔為你收集整理的2.RabbitMQ系列之生产者的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。