自定义实现一个RPC框架（二）

朱雀 2023-02-13 11:51 119阅读 0赞

### 文章目录 ###

*  自定义实现一个RPC框架（二）：
 *   *   *  地址：https://gitee.com/liyunfengfengfeng/rpc
         *  spi
         *  spi基础扩展
         *   *  DubboSpi
             *  JavaSpi
             *  Protocol
             *  HttpProtocol
             *  DubboProtocol
             *  spi配置文件

# 自定义实现一个RPC框架（二）： #

### 地址：https://gitee.com/liyunfengfengfeng/rpc ###

### spi ###

在扩展类的 jar 包内 \[1\]，放置扩展点配置文件 META-INF/dubbo/接口全  
限定名，内容为：配置名=扩展实现类全限定名，多个实现类用换行符分隔。  
resources  
META-INF  
services  
com.luban.framework.Protocol

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bmZlbmdmZW5nZmVuZw_size_16_color_FFFFFF_t_70]

### spi基础扩展 ###

#### DubboSpi ####

package com.luban.spi;
    
    import com.luban.framework.Protocol;
    import com.luban.framework.URL;
    import org.apache.dubbo.common.extension.ExtensionLoader;
    
    public class DubboSpi { 
    
        public static void main(String[] args) { 
            ExtensionLoader<Protocol> extensionLoader =
                    ExtensionLoader.getExtensionLoader(Protocol.class);
            Protocol protocol = extensionLoader.getExtension("http");
            protocol.start(new URL("localhost", 8080));
        }
    }

#### JavaSpi ####

package com.luban.spi;
    
    import com.luban.framework.Protocol;
    import com.luban.framework.URL;
    import com.luban.provider.api.HelloService;
    
    import java.util.Iterator;
    import java.util.ServiceLoader;
    
    public class JavaSpi { 
        public static void main(String[] args) { 
            //jdk的工具类
            ServiceLoader<Protocol> serviceLoader = ServiceLoader.load(Protocol.class);
            Iterator<Protocol> iterator = serviceLoader.iterator();
            while (iterator.hasNext()) { 
                Protocol protocol = iterator.next();
                protocol.start(new URL("localhost", 8080));
            }
        }
    }

#### Protocol ####

package com.luban.framework;
    
    /** * 在扩展类的 jar 包内 [1]，放置扩展点配置文件 META-INF/dubbo/接口全 * 限定名，内容为：配置名=扩展实现类全限定名，多个实现类用换行符分隔。 * resources * META-INF * services * com.luban.framework.Protocol */
    public interface Protocol { 
    
        void start(URL url);
    
        String send(URL url, Invocation invocation);
    }

#### HttpProtocol ####

package com.luban.protocol.http;
    
    import com.luban.framework.Invocation;
    import com.luban.framework.Protocol;
    import com.luban.framework.URL;
    
    public class HttpProtocol implements Protocol { 
    
        @Override
        public void start(URL url) { 
            HttpServer httpServer = new HttpServer();
            httpServer.start(url.getHostname(), url.getPort());
        }
    
        @Override
        public String send(URL url, Invocation invocation) { 
            HttpClient httpClient = new HttpClient();
            return httpClient.send(url.getHostname(), url.getPort(),invocation);
        }
    }

#### DubboProtocol ####

package com.luban.protocol.dubbo;
    
    import com.luban.framework.Invocation;
    import com.luban.framework.Protocol;
    import com.luban.framework.URL;
    
    public class DubboProtocol implements Protocol { 
    
        @Override
        public void start(URL url) { 
            NettyServer nettyServer = new NettyServer();
            nettyServer.start(url.getHostname(), url.getPort());
    
        }
    
        @Override
        public String send(URL url, Invocation invocation) { 
            NettyClient nettyClient = new NettyClient();
            return nettyClient.send(url.getHostname(),url.getPort(), invocation);
        }
    }

#### spi配置文件 ####

http=com.luban.protocol.http.HttpProtocol
    dubbo=com.luban.protocol.dubbo.DubboProtocol

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bmZlbmdmZW5nZmVuZw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200528151130104.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1bmZlbmdmZW5nZmVuZw==,size_16,color_FFFFFF,t_70