Dubbo 4 Dubbo 高级特性 4.2 Dubbo 常用高级配置 4.2.2 地址缓存 4.2.3 超时

news2024/9/25 3:22:08

Dubbo

【黑马程序员Dubbo快速入门，Java分布式框架dubbo教程】

4 Dubbo 高级特性

文章目录

- - Dubbo
  - 4 Dubbo 高级特性
  - - 4.2 Dubbo 常用高级配置
    - - 4.2.2 地址缓存
      - 4.2.3 超时

4.2 Dubbo 常用高级配置

4.2.2 地址缓存

在这里插入图片描述

【一个问题】

如果 注册中心挂了，服务是否可以正常访问？

可以，因为dubbo服务消费者在第一次调用时，会将服务提供方地址缓存到本地，以后在调用则不会访问注册中心。
当服务提供者地址发生变化时，注册中心会通知服务消费者。

【试试】

在这里插入图片描述

上次我们已经实现了一次访问，OK，我现在把 zookeeper 停掉

./zkServer.sh stop

在这里插入图片描述

再试一次，能否正常访问

在这里插入图片描述

OK，效果很明显，就算注册中心挂掉了，【老的】服务依然可以正常访问

4.2.3 超时

【一个场景】

在这里插入图片描述

现在还是有一个消费者和一个提供者

而且它俩分别部署在了 A B 两台机器上

现在来了一个用户来访问服务消费者

在这里插入图片描述

这时服务消费者内部会单独地创建一个线程来去访问服务提供者来调用服务

服务提供者把数据处理好后，把数据返回给服务消费者

在这里插入图片描述

消费者拿到后，再把数据封装一下，就可以返回给用户了

这样整个请求过程就算结束了【线程也就被释放了【或者归还到线程池】】

这是正常理想情况。

【不正常的情况】

服务消费者在调用服务提供者的时候发生了阻塞、等待的情形，这个时候，服务消费者会一直等待下去。

在这里插入图片描述

在某个峰值时刻，大量的请求都在同时请求服务消费者，会造成线程的大量堆积，势必会造成雪崩。

在这里插入图片描述

这样A 机器可能就会因为资源被用光而就会挂掉了。

【Dubbo的解决办法】

dubbo 利用超时机制来解决这个问题，设置一个超时时间，在这个时间段内，无法完成服务访问，则自动断开连接。
使用timeout属性配置超时时间，默认值1000，单位毫秒。

在这里插入图片描述

比如说这里， 3s 种之内，你B 不给我响应，我当前一定断开这个请求

在这里插入图片描述

这样就不会造成 ‘积压’ 了

【试试】

① 在服务提供方，在@Service 注解上配置：

在这里插入图片描述

现在给查 User ，让它睡一会儿

package com.dingjiaxiong.service.impl;

import com.dingjiaxiong.pojo.User;
import com.dingjiaxiong.service.UserService;
import org.apache.dubbo.config.annotation.Service;

/**
 * ClassName: UserServiceImpl
 * date: 2022/11/13 20:27
 *
 * @author DingJiaxiong
 */

//@Service

@Service(timeout = 3000,retries = 0) // 将这个类提供的方法【服务】对外发布，将访问的地址ip、端口、路径注册到 注册中心 中
public class UserServiceImpl implements UserService {
    public String sayHello() {
        return "Hello , Dubbo! DingJiaxiong";
    }

    public User findUserById(int id) {

        // 查询User 对象【这里躲懒了，不走数据库】
        User user = new User(1,"zhangsan","123");

        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        return user;
    }
}

OK。

为了测试效果更明显，修改一下控制器

package com.dingjiaxiong.controller;

import com.dingjiaxiong.pojo.User;
import com.dingjiaxiong.service.UserService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * ClassName: UserController
 * date: 2022/11/13 20:39
 *
 * @author DingJiaxiong
 */

@RestController
@RequestMapping("/user")
public class UserController {

    //注入 Service
//    @Autowired  //这个是本地 注入
    @Reference
    private UserService userService;

    @RequestMapping("/sayHello")
    public String sayHello(){

        return userService.sayHello();
    }

    int i = 1;

    // 根据ID 查询用户信息
    @RequestMapping("/find")
    public User find(int id){

        new Thread(new Runnable() {
            public void run() {
                while (true){
                    System.out.println(i ++);
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        throw new RuntimeException(e);
                    }
                }
            }
        }).start();


        return userService.findUserById(id);
    }

}