2.RabbitMQ系列之生产者
生活随笔
收集整理的這篇文章主要介紹了
2.RabbitMQ系列之生产者
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
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系列之生产者的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： sqlserver 远程链接
- 下一篇： 【Zookeeper】结构、应用、安装部