rpc（远程过程调用），目的是调用远程计算机上的服务，首先，我们先把服务完成
创建服务接口
public interfaceHello {
public void hello(Stringname, inti);
public voidworld();
}
创建接口实现类
public class HelloImp limplements Hello {
public void hello(Stringname, inti) {
System.out.println("hello "+name+" "+i);
}
public void world() {
System.out.println("hello world");
}
}
到此，我们已经完成了服务的开发，接下来，是把开发好的服务提供出去给其他应用调用，这里需要引入注册中心的概念，我们开发的服务，需要注册到注册中心，客户端则通过订阅注册中心的数据，来决定调用的服务。这里也使用了广大人民群众熟知的zookeeper做为注册中心。
接下来重点介绍启动服务发布到注册中心过程
自定义命名空间
因为打造的是属于自己的框架，当然需要有一个属于自己的命名空间（这里LZ所创命名空间为fly），这里需要根据spring的一些规范来拓展，在META-INF目录下分别创建fly.xsd,spring.handles,spring.schemas，然后再创建相应的bean解析类和命名空间处理类，相关的用法有兴趣的朋友可以查看相关资料，这里提供一个链接http://www.cnblogs.com/jifeng/archive/2011/09/14/2176599.html，这样做的目的就是，当应用启动，扫描spring文件加载bean时，spring容器能读取到你自定义命名空间下的配置并且执行你所写的解析类解析配置，如下，服务端配置文件：
启动服务
服务注册到注册中心
启动netty服务端绑定IP和端口
至此，服务发布过程完成！
PS：下面说一下服务发布综合管理类ServiceBean，当spring容器读取到标签是会加载解析并加载，该类实现了spring框架下的ApplicationListener接口，当spring容器加载完成时，会调用onApplicationEvent（）方法，我们把服务发布的 细节放在其方法中，当spring容器加载完毕 产生ContextRefreshedEvent事件时，服务便会随着容器的启动而发布出来
public class ServiceBean implements ApplicationListener {
//接口服务名
private String interfaceClass;
//接口服务实现类
private T ref;
public static final Map exporterMap=new ConcurrentHashMap();
public void export()throwsIllegalAccessException,InstantiationException,UnknownHostException,InterruptedException{
System.out.println("do export.....");
try{
Class clz =Class.forName(interfaceClass);
Method[] methods = clz.getDeclaredMethods();
ArrayList methodNames =newArrayList();
for(Methodm:methods){
methodNames.add(m.getName());
}
String[] methodArray = methodNames.toArray(newString[1]);
URL url =new URL(NetUtil.getHostAddress(),interfaceClass,methodArray,2018);
Object proxy =ProxyFactory.getProxy(ref.getClass());//创建实现类代理
String key =URL.urlEncoder(url.toString());
exporterMap.put(key,proxy);
//get注册中心
ZookeeperRegister register =ZookeeperRegister.getRegister();
register.register(url);//注册服务URL
RpcServer rpcServer =newRpcServer();
rpcServer.start();//启动进程绑定端口
}catch(Exceptione) {
e.printStackTrace();
}
}
public void onApplicationEvent(ApplicationEvent applicationEvent) {
try{
if(ContextRefreshedEvent.class.getName().equals(applicationEvent.getClass().getName())){
export();
}
}catch(IllegalAccessExceptione) {
e.printStackTrace();
}catch(InstantiationExceptione) {
e.printStackTrace();
}catch(UnknownHostExceptione) {
e.printStackTrace();
}catch(InterruptedExceptione) {
e.printStackTrace();
}
}
public String getInterfaceClass() {
return interfaceClass;
}
public void setInterfaceClass(StringinterfaceClass) {
this.interfaceClass= interfaceClass;
}
public T getRef() {
returnref;
}
public void setRef(Tref) {
this.ref= ref;
}
}
网友评论