开远市新农村数字建设网站,php网站开发实用技术答案,简单的小手工,便宜做网站公司接上一篇《RabbitMQ-安装篇#xff08;阿里云主机#xff09;-CSDN博客》
安装好RabbitMQ后#xff0c;我们将开始RabbitMQ的使用#xff0c;根据官网文档RabbitMQ Tutorials | RabbitMQ#xff0c;我们一步一步的学习。
1. Hello World!
这里先说明几个概…接上一篇《RabbitMQ-安装篇阿里云主机-CSDN博客》
安装好RabbitMQ后我们将开始RabbitMQ的使用根据官网文档RabbitMQ Tutorials | RabbitMQ我们一步一步的学习。
1. Hello World!
这里先说明几个概念
生产者指消息的发送方用图例表示。
消费者指消息的接收放用图例表示。
队列(queue)生产者发送的消息将被传递到队列里消费这从队列中消费消息
下面以 生产者 发送消息到队列消费者从队列里消费消息为例演示如何调用Java代码。 RabbitMQ支持多种协议。本教程使用AMQP0-9-1它是一个开放的、通用的消息传递协议。
1.1 下载依赖项
下载客户端库客户端连接库及其依赖项SLF4J API和SLF4J Simple。将这些文件复制到您的工作目录中连同教程Java文件。
1.2 生产者代码-Send.java
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.nio.charset.StandardCharsets;//生产者
public class Send {public static void main(String[] argv) throws Exception {// 创建连接ConnectionFactory factory new ConnectionFactory();factory.setHost(【服务器地址】);factory.setPort(【端口默认5672】);factory.setUsername(【账号】);factory.setPassword(【密码】);factory.setVirtualHost(【虚拟主机】);// 创建信道,发送消息String queueName rc.queue;try (Connection connection factory.newConnection(); Channel channel connection.createChannel()) {channel.queueDeclare(queueName, true, false, false, null);String message Hello World!;channel.basicPublish(, queueName, null, message.getBytes(StandardCharsets.UTF_8));System.out.println( [x] Sent message );}}
}
请将代码中相关配置项设置为您自己的配置。
运行代码即可向RabbitMQ中的rc.queue队列发送一条Hello World消息。rc.queue为我自己创建的请根据实际情况调整 在RabbitMQ后台可以查看到该队列里的消息。
1.3 消费者代码-Recv.java
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;
import java.nio.charset.StandardCharsets;//消费者
public class Recv {public static void main(String[] argv) throws Exception {// 创建连接ConnectionFactory factory new ConnectionFactory();factory.setHost(【服务器地址】);factory.setPort(【端口默认5672】);factory.setUsername(【账号】);factory.setPassword(【密码】);factory.setVirtualHost(【虚拟主机】);// 创建连接通道Connection connection factory.newConnection();Channel channel connection.createChannel();String queueName rc.queue;channel.queueDeclare(queueName, true, false, false, null);System.out.println( [*] Waiting for messages. To exit press CTRLC);DeliverCallback deliverCallback (consumerTag, delivery) - {String message new String(delivery.getBody(), StandardCharsets.UTF_8);System.out.println( [x] Received message );};channel.basicConsume(queueName, true, deliverCallback, consumerTag - {});}
}
运行结果 2.其他模式
调通了1种模式其他模式类似的方式调试即可。RabbitMQ Tutorials | RabbitMQ 3.在Springboot中使用RabbitMQ
3.1 添加依赖
在pom.xml中添加Spring Boot的RabbitMQ依赖。
!--RabbitMQ--
dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId
/dependency 3.2 配置RabbitMQ
在application.properties或application.yml中配置RabbitMQ连接信息。
# application.properties
spring.rabbitmq.host【服务器地址】
spring.rabbitmq.port【端口默认5672】
spring.rabbitmq.username【用户名】
spring.rabbitmq.password【密码】
spring:rabbitmq:host: 【服务器地址】port: 【端口默认5672】username: 【用户名】password: 【密码】 配置Queue、Exchange和Binding
通过Java配置类定义消息队列、交换器和它们之间的绑定关系。
如果在RabbitMQ控制台设置好了Queue、Exchange和Binding无需下面的配置
Configuration
public class RabbitMQConfig {BeanQueue myQueue() {return new Queue(your-queue-name, true);}BeanDirectExchange myExchange() {return new DirectExchange(your-exchange);}BeanBinding binding(Queue myQueue, DirectExchange myExchange) {return BindingBuilder.bind(myQueue).to(myExchange).with(your-routingKey);}
}
3.3 创建消息生产者
定义一个简单的消息生产者类使用RabbitTemplate注解来发送消息到队列
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;Component
public class MessageProducer {private final RabbitTemplate rabbitTemplate;Autowiredpublic MessageProducer(RabbitTemplate rabbitTemplate) {this.rabbitTemplate rabbitTemplate;}public void sendMessage(String message) {rabbitTemplate.convertAndSend(your-queue-name, message);}
}
3.4.创建消息消费者
定义一个消息消费者类使用RabbitListener注解来监听特定的队列
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;Component
public class MessageConsumer {RabbitListener(queues your-queue-name)public void receiveMessage(String message) {System.out.println(Received message: message);}
}
3.5.启动和测试
确保你的应用启动类上有EnableRabbit注解启用RabbitMQ。确保你的RabbitMQ服务正在运行并尝试从你的应用中发送和接收消息。你可以通过调用MessageProducer中的sendMessage方法来测试发送功能而接收功能应该自动触发MessageConsumer中的receiveMessage方法。
