简单 Netty RPC 框架 snrpc

GPL
Java
跨平台
2014-11-20
stefanzhlg

snrpc 是一个简单的 Netty RPC 框架,使用 protostuff 1.07 作为序列化工具,使用 Netty-3.2.1 作为 NIO。

使用方式:

比如:

1. server class;

interface and implementor
        // define an interface:
         public interface SnRpcInterface {
            public String getMessage(String param);
        }
    // implement interface
    public class SnRpcImpl implements SnRpcInterface {
        public String getMessage(String param) {
            return "hi,it is message from server...param+" + param;
        }
    }

2, start server

    SnRpcInterface inter = new SnRpcImpl();
    SnRpcServer server = new SnNettyRpcServer(new Object[] { inter });
    try {
        server.start();
    } catch (Throwable e) {
        e.printStackTrace();
    }

3,config file

snrpcserver.properties

#tcpNoDelay 
snrpc.tcp.nodelay=true
#call the bind method as many times as you want
snrpc.tcp.reuseAddress=true
#ISDEBUG
snrpc.dev=true
#TCP timeout
snrpc.read.timeout=25000
#server port
snrpc.http.port=8080

config.xml

<?xml version="1.0" encoding="UTF-8"?><application>
 <!-- rpc interface services -->    
 <rpcServices>
        <rpcService name="SnRpcInterface" interface="org.stefan.snrpc.server.SnRpcInterface" overload="true">
           <rpcImplementor  class="org.stefan.snrpc.server.SnRpcImpl"/> 
        </rpcService>
    </rpcServices></application>

4, client invoker

    SnRpcConnectionFactory factory = new SnNettyRpcConnectionFactory(
                "localhost", 8080);
    factory = new PoolableRpcConnectionFactory(factory);
    SnRpcClient client = new CommonSnRpcClient(factory);
    try {
        SnRpcInterface clazz = client.proxy(SnRpcInterface.class);
        String message = clazz.getMessage("come on");
        System.out.println("client receive message .... : " + message);
    } catch (Throwable e) {
        e.printStackTrace();
    }

要求

  • JDK6+

  • Maven 2

依赖

  • reflectasm-1.07.jar

  • asm-4.0.jar

  • log4j-1.2.16.jar

  • dom4j-1.6.1.jar

  • xml-apis-1.0.b2.jar

  • slf4j-api-1.6.6.jar

  • netty-3.2.1.Final.jar

  • jaxen-1.1.6.jar

  • protostuff-core-1.0.7.jar

  • protostuff-api-1.0.7.jar

  • protostuff-runtime-1.0.7.jar

  • protostuff-collectionschema-1.0.7.jar

  • commons-pool-1.6.jar


加载中

评论(0)

暂无评论

暂无资讯

暂无问答

一个基于Netty的RPC框架

利用netty写了一个简单的RPC框架,纯粹是为了理解RPC框架。 使用protostuff 1.07 序列化,以netty 3.2.1 网络框架。 下载地址:https://github.com/stefzhlg/snrpc ##How to use e.g. 1,ser...

2014/12/05 15:22
7.4K
2

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部