springboot整合rabbit 根据指定连接信息创建队列
在Spring Boot中整合RabbitMQ,可以通过配置文件指定连接信息,并创建队列。下面是一个示例:
- 在application.properties文件中配置RabbitMQ连接信息:
spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=your-rabbitmq-port
spring.rabbitmq.username=your-rabbitmq-username
spring.rabbitmq.password=your-rabbitmq-password
- 创建一个RabbitMQ配置类,用于创建队列:
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQConfig {
@Bean
public Queue queue() {
return new Queue("your-queue-name");
}
}
- 在应用程序中使用创建的队列:
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
@SpringBootApplication
public class MyApplication {
@Autowired
private RabbitTemplate rabbitTemplate;
public static void main(String[] args) {
ConfigurableApplicationContext context = SpringApplication.run(MyApplication.class, args);
MyApplication application = context.getBean(MyApplication.class);
application.sendMessage("Hello RabbitMQ!");
}
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("your-queue-name", message);
System.out.println("Message sent: " + message);
}
}
在上面的示例中,创建了一个名为"your-queue-name"的队列,并在应用程序中使用RabbitTemplate发送消息到该队列
原文地址: https://www.cveoy.top/t/topic/id9P 著作权归作者所有。请勿转载和采集!