Nacos+SofaRpc 更新订阅端监听器 并发疑问

[symon-lin]

Your question

• 场景：nacos+sofa的集成场景。

• 代码入口：com.alipay.sofa.rpc.registry.nacos.NacosRegistry#subscribe

                if (providerObserver == null) {
                    providerObserver = new NacosRegistryProviderObserver();
                }

                ProviderInfoListener providerInfoListener = config.getProviderInfoListener();
                providerObserver.addProviderListener(config, providerInfoListener);

                EventListener eventListener = new EventListener() {
                    @Override
                    public void onEvent(Event event) {
                        if (event instanceof NamingEvent) {
                            NamingEvent namingEvent = (NamingEvent) event;
                            List<Instance> instances = namingEvent.getInstances();
                            // avoid npe
                            if (null == instances) {
                                instances = new ArrayList<Instance>();
                            }
                            providerObserver.updateProviders(config, instances);
                        }
                    }
                };
                namingService.subscribe(serviceName, defaultCluster, eventListener);
                consumerListeners.put(config, eventListener);

上面的代码中，providerObserver = new NacosRegistryProviderObserver(); 没有对providerObserver进行加锁控制，是否会出现并发的情况下（比如：多模块并行启动），存在多个服务订阅端，然后前面的一个Consumer创建了Observer类，然后后面的Consumer也创建了Observer类并进行覆盖，导致前面的Consumer listener丢失的情况。

Environment

• SOFARPC version:
• JVM version (e.g. java -version): 1.8.0_332
• OS version (e.g. uname -a): Linux statement-group2-6c7c5df77d-vcqs4 5.4.247-162.350.amzn2.aarch64 #1 SMP Tue Jun 27 22:03:50 UTC 2023 aarch64 GNU/Linux
• Maven version: 3.8.4

[nobodyiam]

粗看了下，是会有这个隐患

[symon-lin]

如何解决呢？升级版本？

[EvenLjj]

@symon-lin 这应该是个 bug，当多个 Consumer 共用一个 NacosRegistry 实例时会发生。一种解决方案是 providerObserver 的初始化可以放到 init 方法中去。后续会去修复这个问题，如果感兴趣的话，可以参与贡献。如果你自己的生产代码需要立马修复，可以写个nacos 的 Extension 去覆盖 sofarpc 的实现。