java学习第277天,第五部分学习第5天,RabbitMQ第5天,Dubbo学习第1天,p1-12(07/15)-7h-12集
发布人:shili8
发布时间:2024-12-23 11:31
阅读次数:0
**Java学习日志**
**第277天**
**第五部分学习**
**RabbitMQ学习第5天**
**Dubbo学习第1天**
---
### RabbitMQ学习第5天#### 一、概述在前几天的学习中,我们已经了解了RabbitMQ的基本概念和使用方法。今天,我们将继续深入学习RabbitMQ的高级特性。
#### 二、RabbitMQ高级特性#####2.1、消息持久化RabbitMQ支持消息的持久化,这意味着即使RabbitMQ服务重启或宕机,消息也不会丢失。要开启消息持久化,我们需要在队列和交换器上设置`durable`属性。
java// 创建一个持久化队列channel.queueDeclare("myQueue", true, false, false, null);
#####2.2、消息确认RabbitMQ支持消息确认,这意味着当消费者接收到消息后,可以向RabbitMQ发送确认信号。要开启消息确认,我们需要在交换器上设置`confirm`属性。
java// 创建一个确认队列channel.queueDeclare("myQueue", true, false, false, null); channel.basicQos(1); // 设置确认模式
#####2.3、事务RabbitMQ支持事务,这意味着可以在消息发送和接收之间进行原子操作。要开启事务,我们需要使用`basicPublish`方法。
java// 发送一个事务消息channel.basicPublish("", "myQueue", null, message.getBytes());
#### 三、Dubbo学习第1天#####3.1、概述Dubbo是一个分布式服务框架,支持多语言和多协议。今天,我们将开始学习Dubbo的基本概念和使用方法。
#####3.2、Dubbo基本概念* **Service**: Dubbo中的服务接口。
* **Reference**: Dubbo中的服务引用。
* **Protocol**: Dubbo中的通信协议。
* **Registry**: Dubbo中的服务注册中心。
#### 四、Dubbo示例代码#####4.1、服务提供者
java//服务提供者@Servicepublic class HelloService { public String sayHello(String name) { return "Hello, " + name; } }
#####4.2、服务消费者
java//服务消费者@Referenceprivate HelloService helloService; public void test() { System.out.println(helloService.sayHello("John")); }
#### 五、总结今天,我们学习了RabbitMQ的高级特性和Dubbo的基本概念。我们了解了消息持久化、消息确认、事务等高级特性,以及服务提供者和服务消费者的基本使用方法。
---
**时间:07/15**
**时长:7h**
**集数:12**
---
以上就是今天的学习内容,希望能够帮助你更好地理解RabbitMQ和Dubbo。