BT

如何利用碎片时间提升技术认知与能力? 点击获取答案

Java Remoting远程服务(下)

| 作者 李湃 关注 0 他的粉丝 发布于 2012年2月3日. 估计阅读时间: 22 分钟 | QCon上海2018 关注大数据平台技术选型、搭建、系统迁移和优化的经验。

上篇分别介绍了Java Remoting远程服务中的RMI、EJB、Web Service等技术,下篇继续分享其他的内容。

4. Hessian

Hessian(http://hessian.caucho.com)是一种轻量级的Web Service, 采用的是二进制的RPC协议。

图五:Hessian架构图[5]

如图五所示,Hessian可以形容是一种基于二进制协议提供RMI功能的组件。

接下来我们使用Hessian来实现本文的用例。

  1. 接口类IAnimalService.java
  2. public interface IAnimalService {
        public String getMonkeyName();
    }
  3. 实现类AnimalServiceImp.java
  4. public class AnimalServiceImp implements IAnimalService {
        @Override
        public String getMonkeyName() {
            return "I'm Jacky";
        }
    }
  5. 服务端容器Tomcat配置Web.xml(不需要单独编写Servlet代码)
  6. 
    <servlet>
        <servlet-name>AnimalService</servlet-name>
        <servlet-class>com.caucho.hessian.server.HessianServlet</servlet-class>
        <init-param>
            <param-name>home-class</param-name>
            <param-value>com.demo.AnimalServiceImp</param-value>
        </init-param>
        <init-param>
            <param-name>home-api</param-name>
            <param-value>com.demo.IAnimalService</param-value>
        </init-param>
    </servlet>
    <servlet-mapping>
        <servlet-name>AnimalService</servlet-name>
        <url-pattern>/service/animalService</url-pattern>
    </servlet-mapping>
    </servlet>
  7. 客户端Client.java
  8. final String url = "http://localhost:8080/service/animalService";
    HessianProxyFactory factory = new HessianProxyFactory();
    IAnimalService proxy = (IAnimalService) factory.create(IAnimalService.class, url);
    System.out.println(proxy.getMonkeyName()); 

使用Hessian的利弊:

  • 优势:使用简单,速度快;跨语言,跨平台;可以用来兼容legacy系统的功能。
  • 劣势:安全性的支持不够强,不支持两阶段事务。

通过上面的例子我们可以看出,Hessian使用起来非常简单简单,而且性能评测结果显示Hessian高于基于XML协议的RPC技术(http://daniel.gredler.net/2008/01/07/java-remoting-protocol-benchmarks/)。笔者认为在局域网内Hessian取代WebService是可行的,谁愿意花时间去研究相对笨重的Web Service框架,而且运行相率又很一般呢。大家可能想问,Hessian到底快在哪呢?有两点,首先Hessian采用的是二进制的RPC协议,其次Hessian的序列化速度也比Java本身序列化要快。因而选择Hessian作为解决方案的企业也越来越多。

5. NIO(Mina/Netty)

Java NIO可以理解为我们常说的非阻塞IO(异步IO),这个概念在高并发、多线程的环境里面尤为适用。NIO的基本原理是选择器来处理IO请求,将每个请求做标识,塞入处理队列;每个客户端请求进入睡眠,等待唤醒。

图六:异步IO工作原理[6]

图六展示了异步IO的工作原理,很显然异步IO在高并发的情况下可以节省系统很多资源(对比阻塞IO,异步IO不需要开启同等数量的服务线程)。

接下来我们使用异步IO来实现本文的用例,第三方库使用的是Netty。

  1. 接口类IAnimalService.java, Request.java
    public interface IAnimalService extends Serializable {
        public String getMoneyName();
    }
    public class Request implements Serializable {
        /** 
         * 序列号
         */
        private static final long serialVersionUID = 3701941641993894303L;@SuppressWarnings("rawtypes")
        private Class service; //接口类 
        private String method; //调用方法名称 
        private Object[] paras; //调用方法参数 
        private String version; //服务版本 
        /** 
         * @return the service
         */@SuppressWarnings("rawtypes")
        public Class getService() {
            return service;
        }
        /** 
         * @param service the service to set
         */
        public void setService(Class service) {
            this.service = service;
        }
        /** 
         * @return the method
         */
        public String getMethod() {
            return method;
        }
        /** 
         * @param method the method to set
         */
        public void setMethod(String method) {
            this.method = method;
        }
        /** 
         * @return the paras
         */
        public Object[] getParas() {
            return paras;
        }
        /** 
         * @param paras the paras to set
         */
        public void setParas(Object[] paras) {
            this.paras = paras;
        }
        /** 
         * @return the version
         */
        public String getVersion() {
            return version;
        }
        /** 
         * @param version the version to set
         */
        public void setVersion(String version) {
            this.version = version;
        }
    }
  2. 实现类AnimalServiceImp.java
    public class AnimalServiceImp implements IAnimalService, Serializable {
        /** 
         * 序列号
         */
        private static final long serialVersionUID = -160535222600556362L;@Override
        public String getMoneyName() {
            return "I'am Jackey";
        }
    } 
  3. 服务器端Server.java
    final int port = 9990;
    ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
    bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
        public ChannelPipeline getPipeline() throws Exception {
            ChannelPipeline pipeLine = Channels.pipeline(new SimpleChannelUpstreamHandler() {
                @Override
                public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
                    //监听消息到达 
                    Request obj = (request) e.getMessage();
                    if (obj.getService().equals(IAnimalService.class)) {
                        Method targetMethod = obj.getService().getMethod(obj.getMethod(), new Class[0]);
                        Object result = targetMethod.invoke(new AnimalServiceImp(), obj.getParas());
                        e.getChannel().write(result);
                    }
                }
            });
            pipeLine.addFirst("encoder", new ObjectEncoder()); //对象编码器 
            pipeLine.addFirst("decoder", new ObjectDecoder()); //对象解码器 
            return pipeLine;
        }
    });
    bootstrap.bind(new InetSocketAddress(port)); //启动服务并绑定端口 
  4. 客户端代码Client.java
    ClientBootstrap client = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool())); 
    client.setPipelineFactory(new ChannelPipelineFactory() { 
        public ChannelPipeline getPipeline() throws Exception { 
            ChannelPipeline pipeLine = Channels.pipeline(new SimpleChannelUpstreamHandler() { 
                @Override 
                public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) { 
                    //创建连接发送请求 
                    Request r = new Request(); 
                    r.setVersion("1.0.0"); //设置版本 
                    r.setService(IAnimalService.class); //设置服务类型 
                    r.setMethod("getMoneyName"); //调用服务方法名称 
                    r.setParas(null); //参数 
                    e.getChannel().write(r); 
                } 
                @Override 
                public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception{ 
                    //监听消息到达 
                    System.out.println(e.getMessage().toString()); 
                } 
            }); 
            pipeLine.addFirst("encoder", new ObjectEncoder()); //对象编码器 
            pipeLine.addFirst("decoder", new ObjectDecoder()); //对象解码器 
            return pipeLine; 
        } 
    }); 
    client.setOption("tcpNoDelay", true); 
    client.setOption("keepAlive", true); 
    ChannelFuture future = client.connect(new InetSocketAddress("127.0.0.1", 9990)); 
    future.getChannel().getCloseFuture().awaitUninterruptibly(); 
    client.releaseExternalResources(); //释放外部资源 

上述代码的实现稍有复杂,主要的结构是客户端将请求对象编码并发送管道,服务端将接受的字节流解码为对象,调用相应的方法并将结果返还至客户端。感兴趣的读者可以查看Netty官网(http://www.jboss.org/netty)来了解详情。

中国最大的互联网公司之一,淘宝,内部使用的服务框架HSF就采用了这种方式(采用的第三方NIO库是Mina)[7] 。笔者认为使用NIO这种方式来做分布式应用的优劣也是非常明显的:

  1. 优点:基于TCP通信,效率上高于HTTP的方式,非阻塞IO应对高并发绰绰有余。根据具体的需要制定数据传输的格式,可扩展性强。
  2. 缺点:不能跨语言,无法穿透防火墙。

结论

对企业来讲,Java Remoting采取何种方案没有一个特定的标准。根据笔者的经验,业务特点以及数据吞吐量决定了技术的选择方向。比如第三方数据接口,重点考虑的是跨平台、跨语言、支持高并发、保证安全;而局域网内的分布式服务,重点考虑的是高性能、稳定性、可伸缩性。

引用

[5] http://safehammad.com/tag/hessian/

[6] http://onjava.com/onjava/2002/09/04/nio.html

[7] http://archive.cnblogs.com/a/1963077/

[8] http://www.salesforce.com/us/developer/docs/api/index.htm

作者

李湃,上海交通大学计算机硕士毕业,5年互联网的行业经验,现就职于国内某互联网公司,喜欢开源技术,对于Java企业架构、分布式技术、高性能高可靠软件设计有极大的热情,希望能对国内社区有所贡献。博客地址:http://haperkelu2011.iteye.com/


感谢崔康对本文的审校。

给InfoQ中文站投稿或者参与内容翻译工作,请邮件至editors@cn.infoq.com。也欢迎大家通过新浪微博(@InfoQ)或者腾讯微博(@InfoQ)关注我们,并与我们的编辑和其他读者朋友交流。

评价本文

专业度
风格

您好,朋友!

您需要 注册一个InfoQ账号 或者 才能进行评论。在您完成注册后还需要进行一些设置。

获得来自InfoQ的更多体验。

告诉我们您的想法

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

Hessian不支持javascript by yang Terryang

Hessian不支持javascript??

Re: Hessian不支持javascript by 杨 振涛

目前官方还没有javascript的实现支持,但我想肯定有其他民间实现版本; 官方的主要是主流的服务器端语言的实现,如 Java
Flash/Flex
Python
C++
.NET C#
D
Erlang
PHP
Ruby
Objective C

除了NIO之外,没感觉比.net的Remoting多了什么 by Top Gun

.net的Remoting技术2005年就有了

Java NIO为同步非阻塞IO不是异步IO by nie yong

Java NIO为同步非阻塞IO不是异步IO,这才是正确的说法。

发文章请先自己搞明白NIO和AIO区别。 by 张 蒙蒙

NIO不是异步IO。
发文章请先自己搞明白NIO和AIO区别。

Re: 发文章请先自己搞明白NIO和AIO区别。 by 哈哈 呵呵

这家伙其实是没明白NIO

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

允许的HTML标签: a,b,br,blockquote,i,li,pre,u,ul,p

当有人回复此评论时请E-mail通知我

6 讨论

登陆InfoQ,与你最关心的话题互动。


找回密码....

Follow

关注你最喜爱的话题和作者

快速浏览网站内你所感兴趣话题的精选内容。

Like

内容自由定制

选择想要阅读的主题和喜爱的作者定制自己的新闻源。

Notifications

获取更新

设置通知机制以获取内容更新对您而言是否重要

BT