摘要：源碼分析一該類繼承，是協(xié)議實現(xiàn)的核心。屬性默認端口號不支持服務(wù)暴露可以看到，服務(wù)暴露方法直接拋出異常。后記該部分相關(guān)的源碼解析地址該文章講解了遠程調(diào)用中關(guān)于協(xié)議實現(xiàn)的部分，邏輯比較簡單。

目標：介紹memcached協(xié)議的設(shè)計和實現(xiàn)，介紹dubbo-rpc-memcached的源碼。

dubbo實現(xiàn)memcached協(xié)議是基于Memcached，Memcached 是一個高效的 KV 緩存服務(wù)器，在dubbo中沒有涉及到關(guān)于memcached協(xié)議的服務(wù)暴露，只有服務(wù)引用，因為在訪問Memcached服務(wù)器時，Memcached客戶端可以在服務(wù)器上存儲也可以獲取。

該類繼承AbstractProtocol，是memcached協(xié)議實現(xiàn)的核心。

/**
 * 默認端口號
 */
public static final int DEFAULT_PORT = 11211;

@Override
public  Exporter export(final Invoker invoker) throws RpcException {
    // 不支持memcached服務(wù)暴露
    throw new UnsupportedOperationException("Unsupported export memcached service. url: " + invoker.getUrl());
}

可以看到，服務(wù)暴露方法直接拋出異常。

@Override
public  Invoker refer(final Class type, final URL url) throws RpcException {
    try {
        // 獲得地址
        String address = url.getAddress();
        // 獲得備用地址
        String backup = url.getParameter(Constants.BACKUP_KEY);
        // 把備用地址拼接上
        if (backup != null && backup.length() > 0) {
            address += "," + backup;
        }
        // 創(chuàng)建Memcached客戶端構(gòu)造器
        MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil.getAddresses(address));
        // 創(chuàng)建客戶端
        final MemcachedClient memcachedClient = builder.build();
        // 到期時間參數(shù)配置
        final int expiry = url.getParameter("expiry", 0);
        // 獲得值命令
        final String get = url.getParameter("get", "get");
        // 添加值命令根據(jù)類型來取決是put還是set
        final String set = url.getParameter("set", Map.class.equals(type) ? "put" : "set");
        // 刪除值命令
        final String delete = url.getParameter("delete", Map.class.equals(type) ? "remove" : "delete");
        return new AbstractInvoker(type, url) {
            @Override
            protected Result doInvoke(Invocation invocation) throws Throwable {
                try {
                    // 如果是獲取方法名的值
                    if (get.equals(invocation.getMethodName())) {
                        // 如果參數(shù)長度不等于1，則拋出異常
                        if (invocation.getArguments().length != 1) {
                            throw new IllegalArgumentException("The memcached get method arguments mismatch, must only one arguments. interface: " + type.getName() + ", method: " + invocation.getMethodName() + ", url: " + url);
                        }
                        // 否則調(diào)用get方法來獲取
                        return new RpcResult(memcachedClient.get(String.valueOf(invocation.getArguments()[0])));
                    } else if (set.equals(invocation.getMethodName())) {
                        // 如果參數(shù)長度不為2，則拋出異常
                        if (invocation.getArguments().length != 2) {
                            throw new IllegalArgumentException("The memcached set method arguments mismatch, must be two arguments. interface: " + type.getName() + ", method: " + invocation.getMethodName() + ", url: " + url);
                        }
                        // 無論任何現(xiàn)有值如何，都在緩存中設(shè)置一個對象
                        memcachedClient.set(String.valueOf(invocation.getArguments()[0]), expiry, invocation.getArguments()[1]);
                        return new RpcResult();
                    } else if (delete.equals(invocation.getMethodName())) {
                        // 刪除操作只有一個參數(shù)，如果參數(shù)長度不等于1，則拋出異常
                        if (invocation.getArguments().length != 1) {
                            throw new IllegalArgumentException("The memcached delete method arguments mismatch, must only one arguments. interface: " + type.getName() + ", method: " + invocation.getMethodName() + ", url: " + url);
                        }
                        // 刪除某個值
                        memcachedClient.delete(String.valueOf(invocation.getArguments()[0]));
                        return new RpcResult();
                    } else {
                        // 不支持的操作
                        throw new UnsupportedOperationException("Unsupported method " + invocation.getMethodName() + " in memcached service.");
                    }
                } catch (Throwable t) {
                    RpcException re = new RpcException("Failed to invoke memcached service method. interface: " + type.getName() + ", method: " + invocation.getMethodName() + ", url: " + url + ", cause: " + t.getMessage(), t);
                    if (t instanceof TimeoutException || t instanceof SocketTimeoutException) {
                        re.setCode(RpcException.TIMEOUT_EXCEPTION);
                    } else if (t instanceof MemcachedException || t instanceof IOException) {
                        re.setCode(RpcException.NETWORK_EXCEPTION);
                    }
                    throw re;
                }
            }

            @Override
            public void destroy() {
                super.destroy();
                try {
                    // 關(guān)閉客戶端
                    memcachedClient.shutdown();
                } catch (Throwable e) {
                    logger.warn(e.getMessage(), e);
                }
            }
        };
    } catch (Throwable t) {
        throw new RpcException("Failed to refer memcached service. interface: " + type.getName() + ", url: " + url + ", cause: " + t.getMessage(), t);
    }
}

該方法是服務(wù)引用方法，基于MemcachedClient的get、set、delete方法來對應(yīng)Memcached的get、set、delete命令進行對值的操作。

該部分相關(guān)的源碼解析地址：https://github.com/CrazyHZM/i...

該文章講解了遠程調(diào)用中關(guān)于memcached協(xié)議實現(xiàn)的部分，邏輯比較簡單。接下來我將開始對rpc模塊關(guān)于redis協(xié)議部分進行講解。