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

叁歲伎倆 2023-02-13 11:51 11阅读 0赞

### 文章目录 ###

*  自定义实现一个RPC框架（四）：
 *   *   *  地址：https://gitee.com/liyunfengfengfeng/rpc
         *  provider
         *   *  provider
             *  接口
             *  实现类
             *  本地注册中心

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

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

### provider ###

#### provider ####

package com.luban.provider;
    
    import com.luban.framework.Protocol;
    import com.luban.framework.ProtocolFactory;
    import com.luban.framework.URL;
    import com.luban.protocol.dubbo.NettyServer;
    import com.luban.protocol.http.HttpProtocol;
    import com.luban.protocol.http.HttpServer;
    import com.luban.provider.api.HelloService;
    import com.luban.provider.impl.HelloServiceImpl;
    import com.luban.register.RemoteMapRegister;
    import com.luban.register.ZookeeperRegister;
    
    public class Provider { 
    
        private static boolean isRun = true;
    
        public static void main(String[] args) { 
            // 1. 注册服务
            // 2. 本地注册
            // 3. 启动tomcat
    
            // 注册服务
            URL url = new URL("localhost", 8080); //NetUtil
            RemoteMapRegister.regist(HelloService.class.getName(), url);
    
            // 服务：实现类
            LocalRegister.regist(HelloService.class.getName(), HelloServiceImpl.class);
    
            //选择基于dubbo实现 还是HTTP实现
            Protocol protocol = ProtocolFactory.getProtocol();
            protocol.start(url);
    
    
        }
    }

#### 接口 ####

package com.luban.provider.api;
    
    public interface HelloService { 
    
        String sayHello(String userName);
    }

#### 实现类 ####

package com.luban.provider.impl;
    
    import com.luban.provider.api.HelloService;
    
    public class HelloServiceImpl implements HelloService { 
    
        @Override
        public String sayHello(String userName) { 
            return "Hello: " + userName;
        }
    }

#### 本地注册中心 ####

package com.luban.provider;
    
    import java.util.HashMap;
    import java.util.Map;
    
    
    public class LocalRegister { 
    
        private static Map<String, Class> map = new HashMap<>();
    
        public static void regist(String interfaceName, Class implClass) { 
            map.put(interfaceName, implClass);
        }
    
        public static Class get(String interfaceName) { 
           return map.get(interfaceName);
        }
    }