light-rpc

KO | EN

gitlite — search

#typescript #android #machine-learning #rust #deep-learning #linux #docker #nodejs #macos #windows #kubernetes #ios #mcp #openai

(★ 16)

light ,easy use ,extendable ,distributed java rpc framework based on zookeeper over http

light-rpc 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

### light-rpc
light-rpc是一个java分布式rpc框架，基于zookeeper进行进行服务注册和发现，方便扩展，支持多种序列化协议，如java原生，hessian,FST等。
默认使用http进行传输协议，数据传输协议可自由扩展。

### 安装与运行服务端示例代码
安装步骤<br>
 - 下载light-rpc
```
     git clone https://github.com/dengqiao/light-rpc.git
```
 - 导入下载的maven项目代码到eclipse中<br>
 - 扩展AbstractRpcServlet<br>
```
    package com.github.dengqiao.rpc.example;

import java.util.List;
    
    import com.github.dengqiao.rpc.core.ServiceProfile;
    import com.github.dengqiao.rpc.core.codec.impl.FstCodec;
    import com.github.dengqiao.rpc.server.AbstractRpcServlet;
    import com.github.dengqiao.rpc.server.ServiceExporter;
    
    public class SoRpcServlet extends AbstractRpcServlet {
      //注册ServiceExporter到seList，该例子使用java直接初始化对象，
         也可以实现从spring容器中获取ServiceExporter Bean
    	public void registerServiceExporter(ServiceProfile sp, 
    	           List<ServiceExporter> seList) throws Exception{
    		ServiceExporter se = new ServiceExporter();
    		se.setTarget(new SoServiceImpl());
    		se.setServiceInterface(SoService.class);
    		se.setServiceProfile(sp);
    		se.init();
    		seList.add(se);
    	}
    	//返回rpc服务配置信息
    	public ServiceProfile  getServiceProfile(){
    		ServiceProfile  sp = new ServiceProfile();
    		//设置tomcat等容器的应用相对路径
    		sp.setServerContextPath("gos");
    		//设置tomcat等容器的网络端口
    		sp.setServerPort("8080");
    		//设置应用名称，用于服务注册时zookeeper路径
    		sp.setServiceAppName("gos-query");
    		sp.setServiceVersion("0.01");
    		//设置web.xml中AbstractRpcServlet请求的url前缀
    		sp.setUrlPrefix("rpc");
    		//设置服务端序列化实现
    		sp.setRpcCodec(new FstCodec());
    		return sp;
    	}
    
    }
```
- 启动zookeeper服务<br>
- mvn package打包项目代码，发布到tomcat中，注意ServiceProfile 中ServerContextPath配置正确，
   并且添加jvm 参数-DzkConnStr对应的zookeeper连接信息到tomcat启动参数中
  
### 安装与运行客服端代码，示例如下见JdkRpcProxyFactoryTest类
```
     package com.github.dengqiao.rpc.client;

import com.alibaba.fastjson.JSON;
import com.github.dengqiao.rpc.core.ClientProfile;
import com.github.dengqiao.rpc.core.ServiceProfile;
import com.github.dengqiao.rpc.core.codec.impl.FstCodec;
import com.github.dengqiao.rpc.example.So;
import com.github.dengqiao.rpc.example.SoService;

public class JdkRpcProxyFactoryTest {

public static void main(String[] args) {
		ClientProfile cp = new ClientProfile();
		cp.setClientAppName("test");
		cp.setServiceAppName("gos-query");
		cp.setServiceVersion("0.01");
		cp.setRpcCodec(new FstCodec());
		cp.setReadTimeout(30000);
		
		ServiceLocator sl = new ZkServiceLocator();
		sl.setClientProfile(cp);
		
		SoService service = 
				(SoService)JdkRpcProxyFactoryBean.create(SoService.class, sl);
		So so = service.getSoById(2L);
		System.out.println(JSON.toJSONString(so));
		
	}

}
```
注意在运行此客户端代码时也需要添加jvm 参数-DzkConnStr对应的zookeeper连接信息

light-rpc

light-rpc 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

light-rpc

light-rpc 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README