dubbo分组与多版本

---

dubbo 分组与多版本

              

服务分组：https://dubbo.apache.org/zh/docs/advanced/service-group/

多版本：https://dubbo.apache.org/zh/docs/advanced/multi-versions/

                     

                            

                               

分组与多版本

              

分组：一个接口有多个实现，可以用group来区分

# 服务提供端# 服务消费端：消费指定分组# 服务消费端：消费任意分组

          

多版本：接口需要升级时可用版本来区分，升级到新版本后，旧版本下线

# 服务提供端旧版本（1.0.0）# 服务提供端新版本（2.0.0）# 消费端消费旧版本（1.0.0）# 消费端消费新版本（2.0.0）# 消费端消费任意版本（*）：不会调用不携带version的服务端服务

          

版本升级步骤

在低压力时间，将一半服务提供端升级为新版本将消费逐渐切换到新版本服务进行消费全部消费端切换到新版本服务消费后，旧版本服务下线

            

                 

                               

实现原理

             

AbstractProtocol：服务暴露过程中存储exporter，供后续消费时使用

public abstract class AbstractProtocol implements Protocol, ScopeModelAware { protected final Logger logger = LoggerFactory.getLogger(getClass()); protected final Map> exporterMap = new ConcurrentHashMap<>(); //key：group/serviceName:version:port //value：服务对应的exporter，dubbo协议为dubboExporter、triple协议为new AbstractExporter protected final Map serverMap = new ConcurrentHashMap<>(); //dubbo协议中使用，存储服务端创建的server // TODO SoftReference protected final Set> invokers = new ConcurrentHashSet<>(); protected frameworkModel frameworkModel; @Override public void setframeworkModel(frameworkModel frameworkModel) { this.frameworkModel = frameworkModel; } protected static String serviceKey(URL url) { int port = url.getParameter(Constants.BIND_PORT_KEY, url.getPort()); return serviceKey(port, url.getPath(), url.getVersion(), url.getGroup()); } protected static String serviceKey(int port, String serviceName, String serviceVersion, String serviceGroup) { return ProtocolUtils.serviceKey(port, serviceName, serviceVersion, serviceGroup); } //构建exporterMap的key，格式为：group/serviceName:version:port

                  

服务端服务暴露（dubbo）

public class DubboProtocol extends AbstractProtocol { @Override public Exporter export(Invoker invoker) throws RpcException { checkDestroyed(); URL url = invoker.getUrl(); // export service. String key = serviceKey(url); DubboExporter exporter = new DubboExporter(invoker, key, exporterMap); //export a stub service for dispatching event Boolean isStubSupportEvent = url.getParameter(STUB_EVENT_KEY, DEFAULT_STUB_EVENT); Boolean isCallbackservice = url.getParameter(IS_CALLBACK_SERVICE, false); if (isStubSupportEvent && !isCallbackservice) { String stubServiceMethods = url.getParameter(STUB_EVENT_METHODS_KEY); if (stubServiceMethods == null || stubServiceMethods.length() == 0) { if (logger.isWarnEnabled()) { logger.warn(new IllegalStateException("consumer [" + url.getParameter(INTERFACE_KEY) + "], has set stubproxy support event ,but no stub methods founded.")); } } } openServer(url); optimizeSerialization(url); return exporter; }

                   

服务端接收到消费请求处理

public class DubboProtocol extends AbstractProtocol { private ExchangeHandler requestHandler = new ExchangeHandlerAdapter() { @Override public CompletableFuture