我们之前将的是,直接使用java代码操作rabbitmq,相当于就是原生的代码操作rabbitmq,但是之后我们在项目里面,不会使用原生的java代码操作rabbitmq的,所以现在我们要将springboot项目是如何整合rabbitmq的。项目里面是如何使用rabbitmq的。
以下将会分别的讲解springboot项目是如何操作5种模型的。
直接使用简单的springboot项目来说5种模型
创建springboot项目
1 创建springboot项目
这个项目是用脚手架直接生成的,那么就直接导入了web 依赖和rabbit的依赖
代码语言:javascript复制 <dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
2 配置文件里面写rabbitmq的用户名和密码
之前我们用java代码的源码操作的时候,用户名和密码是直接写在工具类里面的,但是现在我们是整合了springboot,所以只需要在yml里面写配置就可以了。
以后就可以直接使用rabbitTemplates 进行操作rabbitmq
3 在测试类里面直接操作rabbitmq
之前只用java原生代码操作rabbitmq的时候,有5种模型
第一个模型
直接发送消息到队列里面
在项目里面监听队列,我们就创建一个类,用来监听队列,这个使用注解的方式进行开发 在rabbitmq软件里面之前是没有队列的,我们只用提供者提供的时候,不会直接创建队列的,我们只能在消费者里面监听的时候创建队列,就是消费者在消费的时候,没有队列就创建队列。
消费者
代码语言:javascript复制@Component 将这个类配置到spring容器里面
@RabbitListener(queuesToDeclare = @Queue("hello")) 一直在监听这个队列
public class HelloCustomer {
@RabbitHandler 这个注解的意思是 只要监听到这个队列里面有消息,那么就执行下面的方法
public void receivel(String message){ message 就是这个队列里面的消息
System.out.println("message=" message);
}
}
只要写上面的类,这个就一直在监听,现在就等 提供者发消息了。
提供者
代码语言:javascript复制@SpringBootTest
class SpringbootRabbitmqApplicationTests {
@Autowired
private RabbitTemplate rabbitTemplate;
@Test
void contextLoads() {
//使用rabbitmq直接往队列里面放数据
// convertAndSend()第一个参数 是
rabbitTemplate.convertAndSend("hello","hello world");
}
}
意思就是使用rabbitTemplate直接发送消息
但是这个默认的是 直接创建的队列是持久化的,那么如何利用代码进行操作,可以利用代码进行配置是不是持久化呢?
以上的这个方法里面还可以写其他的参数,其他的参数就可以进行限制
代码语言:javascript复制@Component
@RabbitListener(queuesToDeclare = @Queue(value = "hello",durable = "false",autoDelete = "true"))
public class HelloCustomer {
@RabbitHandler
public void receivel(String message){
System.out.println("message=" message);
}
}
durable属性就是设置是不是要持久化 autoDelete属性是设置是不是要自动删除
总结
1 创建一个springboot项目 2 导入rabbitmq的依赖 3 配置用户名和密码 4 使用rabbittemplate 进行往 rabbitmq里面发数据 5 使用注解进行监听队列 ,并且将队列里面的消息输出
以上只是单纯的使用了队列,没有使用交换机,也是我们之前讲的第一个模型