解决微服务乱入问题

2022-12-28 15:34 栏目: 技术学堂 查看()
1、遇到的问题
         有A,B,C 三个微服务,在服务器s1上部署,我本地开发A微服务和B微服务接口的时候,希望我自己机器的A能调用的我自己机器的B上来,如果我自己没有启动B在调用到S1的B上去。默认情况下我可能调用了多次B 只有一半几率命中到我自己机器,其他的请求都跑到S1去了。
 
2、解决思路
       一般情况我们使用 ribbon 来做负载均衡,也就是说,具体调用哪个微服务是 ribbon 说了算,我们可以自定义ribbon的负载均衡规则来让他优先将请求命中到我自己这台机器上。
 
3、自定义规则代码
/**
 * nacos dev环境微服务调度规则
 * 优先同IP,第二同网段
 * debugger.local-ip 请配置为本机在nacos上的那个IP
 * by 王磊
 */
public class DevNacosDebuggerRuleConfig extends AbstractLoadBalancerRule {
 
    @Value("${debugger.local-ip:}")
    private String localIp;
 
    @Autowired
    private NacosDiscoveryProperties nacosDiscoveryProperties;
 
    /**
     * 重写choose方法
     *
     * @param key
     * @return
     */
    @SneakyThrows
    @Override
    public Server choose(Object key) {
        //获取负载均衡器
        BaseLoadBalancer baseLoadBalancer = (BaseLoadBalancer) getLoadBalancer();
        //调用服务的名字
        String invokedServerName = baseLoadBalancer.getName();
        //获取namingServer(包含nacos注册发现相关api)
        NamingService namingService = nacosDiscoveryProperties.namingServiceInstance();
        //获取被调用的服务的所有实例
        List<Instance> invokedAllInstanceList = namingService.getAllInstances(invokedServerName);
        if (invokedAllInstanceList.isEmpty()) {
            throw new RuntimeException(invokedServerName + "找不到服务,请检查服务提供者是否已经启动并且已经注册到nacos中");
        }
        Instance invokedInstance = null;
        String localIp = this.getLocalhostIp();
        //192.168.0  获取到同网段ip
        String localIpStart = localIp.substring(0, localIp.lastIndexOf("."));
        //他的优先级比较高
        Instance l1InvokedInstance = null;
        for (Instance instance : invokedAllInstanceList) {
            if (instance.getIp().equals(localIp)) {
                return new NacosServer(instance);
            } else if (instance.getIp().startsWith(localIpStart)) {
                invokedInstance = instance;
            } else if (instance.getIp().equals("192.168.16.229")) {
                l1InvokedInstance = instance;
            }
        }
        invokedInstance = l1InvokedInstance == null ? invokedInstance : l1InvokedInstance;
        return new NacosServer(invokedInstance != null ? invokedInstance : invokedAllInstanceList.get(0));
    }
 
 
    @Override
    public void initWithNiwsConfig(IClientConfig iClientConfig) {
 
    }
 
    /**
     * 获取本地ip
     *
     * @return 本机ip
     */
    public String getLocalhostIp() {
        if (!StringUtils.isEmpty(localIp)) {
            return localIp;
        }
        try {
            Enumeration<NetworkInterface> allNetInterfaces = NetworkInterface.getNetworkInterfaces();
            while (allNetInterfaces.hasMoreElements()) {
                NetworkInterface netInterface = (NetworkInterface) allNetInterfaces.nextElement();
                Enumeration<InetAddress> addresses = netInterface.getInetAddresses();
                while (addresses.hasMoreElements()) {
                    InetAddress ip = (InetAddress) addresses.nextElement();
                    if (ip != null
                            && ip instanceof Inet4Address
                            && !ip.isLoopbackAddress() //loopback地址即本机地址,IPv4的loopback范围是127.0.0.0 ~ 127.255.255.255
                            && ip.getHostAddress().indexOf(":") == -1) {
                        return ip.getHostAddress();
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }
}
4、yml中配置哪些微服务使用此规则
purchase: #purchase 是微服务名字要和nacos里注册的一致
  ribbon:
    NFLoadBalancerRuleClassName: com.xx.bos.gateway.config.DevNacosDebuggerRuleConfig
 
扫二维码与商务沟通

我们在微信上24小时期待你的声音

解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流

郑重申明:小伙伴科技以外的任何非授权单位或个人,不得使用我公司案例作为工作成功展示!