`

yanf4j引入了客户端非阻塞API

    博客分类:
  • java
阅读更多

yanf4j 发布一个0.50-beta2 版本,这个版本最重要的改进就是引入了客户端连接非阻塞AP I,主要最近的工作要用到,所以添加了。两个核心类TCPConnectorControllerUDPConnectorController 分别用于TCP和UDP的客户端连接控制。例如,现在的UDP echo client可以写成:

<!---->     // 客户端echo handler
     class  EchoClientHandler  extends  HandlerAdapter {

        
public   void  onReceive(Session udpSession, Object t) {
            DatagramPacket datagramPacket 
=  (DatagramPacket) t;
            System.out.println(
" recv: "   +   new  String(datagramPacket.getData()));
        }

        @Override
        
public   void  onMessageSent(Session session, Object t) {
            System.out.println(
" send: "   +   new  String(( byte []) t));
        }

    }

       // 连接代码,并发送UDP包

        UDPConnectorController connector 
=   new  UDPConnectorController();
        connector.setSoTimeout(
1000 );
        connector.setHandler(
new  EchoClientHandler());
        connector.connect(
new  InetSocketAddress(InetAddress.getByName(host),
                port));
        
for  ( int  i  =   0 ; i  <   10000 ; i ++ ) {
            String s 
=   " hello  "   +  i;
            DatagramPacket packet 
=   new  DatagramPacket(s.getBytes(), s.length());
            connector.send(packet);
        }


    UDP不是面向连接的,因此connect方法仅仅是调用了底层DatagramChannel.connect方法,用来限制接收和发送的packet的远程端点。

    再来看看TCPConnectorController的使用,同样看Echo Client的实现:

<!---->// 客户端的echo handler
class  EchoHandler  extends  HandlerAdapter < String >  {

        @Override
        
public   void  onConnected(Session session) {
            
try  {
                
// 一连接就发送NUM个字符串
                 for  ( int  i  =   0 ; i  <  NUM; i ++ )
                    session.send(generateString(i));
             } 
catch  (Exception e) {

             }
        }

        
public  String generateString( int  len) {
            StringBuffer sb 
=   new  StringBuffer();
            
for  ( int  i  =   0 ; i  <  MESSAGE_LEN; i ++ )
                sb.append(i);
            
return  sb.toString();
        }

        @Override
        
public   void  onReceive(Session session, String t) {
            // 打印接收到字符串
             if  (DEBUG)
                System.out.println(
" recv: "   +  t);
            
        }

    }


// ...连接API,TCPConnectorController示例
    Configuration configuration  =   new  Configuration();
        configuration.setTcpSessionReadBufferSize(
256   *   1024 );  //  设置读的缓冲区大小
    TCPConnectorController    connector  =   new  TCPConnectorController(configuration,
                
new  StringCodecFactory());
    connector.setHandler(
new  EchoHandler());
    connector.setCodecFactory(
new  StringCodecFactory());
   
try  {
            connector.Connect(
new  InetSocketAddress( " localhost " 8080 ));
    } 
catch  (IOExceptione) {
            e.printStackTrace();
    }


    注意,connect方法并不阻塞 ,而是立即返回,连接是否建立可以通过TCPConnectorController.isConnected()方法来判断,因此通常你可能会这样使用:

<!---->try  {
            connector.Connect(
new  InetSocketAddress( " localhost " 8080 ));
            
while ( ! connector.isConnected())
                ;
        } 
catch  (Exception e) {
            e.printStackTrace();
        }


    来强制确保后面对connector的使用是已经连接上的connector,然而更好的做法是在Handler的onConnected()回调方法中处理逻辑,因为这个方法仅仅在连接建立后才会被调用。
    两个ConnectorController都有系列send方法,用于发送数据:

<!---->TCPConnectorController.send(Object msg)  throws  InterruptedException
UDPConnectorController.send(DatagramPacket packet) 
throws  InterruptedException
UDPConnectorController.send(SocketAddress targetAddr, Object msg)
throws  InterruptedException



    0.50-beta2带来的另一个修改就是Session接口添加setReadBufferByteOrder 方法,用于设置session接收缓冲区的字节序,默认是网络字节序,也就是大端法。这个方法建议在Handler的onSessionStarted回调方法中调用。

    在0.50-beta最重要的修改是引入了session发送队列缓冲区的流量控制选项 。默认情况下,session的发送缓冲队列是无界的,队列的push和pop也全然不会阻塞。在设置了缓冲队列的高低水位选项后即引入了发送流量控制,规则如下:
a)当发送队列中的数据总量大于高水位标记(highWaterMark),Session.send将阻塞
b)在条件a的作用下,Session.send的阻塞将持续到发送队列中的数据总量小于于低水位标记(lowWaterMark)才解除。


缓冲队列高低水位的设置通过Controller的下列方法设置:

<!---->     public   void  setSessionWriteQueueHighWaterMark( int  highWaterMark);

     
public   void  setSessionWriteQueueLowWaterMark( int  lowWaterMark);

 
缓冲队列的流量控制想法来自ACE的ACE_Message_Queue,是通过com.google.code.yanf4j.util.MessageQueue类实现的。

   0.50-beta还引入了Session.send(Object msg)的重载版本 Session.send(Object msg,long timeout),在超过timeout时间后send仍然阻塞时即终止send。注意,现在Session.send的这两个方法都返回一个bool值来表示send成功与否,并且都将响应中断(仅限启动了流量控制选项)抛出InterruptedException。

分享到:
评论

相关推荐

    Xmemcached一个java实现的分布式缓存

    这个库的主要目标是提供简单、快速、无阻塞的客户端API,以便于开发人员在Java应用程序中集成和利用Memcached的强大功能。下面将详细讨论Xmemcached的关键特性和使用方法。 1. **Memcached简介** Memcached是一种...

    xmemcached 中文开发手册

    1.2.5版之后,yanf4j已经被整合入XMemcached本身,无需额外依赖。 #### 使用指南 - **依赖包**:XMemcached依赖于SLF4J日志框架。 - 对于使用Maven构建项目的用户,可以通过简单的依赖声明(如上述示例)轻松集成...

    memcached客户端和服务端程序和jar包

    import com.google.code.yanf4j.config.Configuration; import net.rubyeye.xmemcached.MemcachedClient; // 初始化客户端 Configuration conf = new Configuration("localhost:11211"); MemcachedClient client = ...

    Xmemcached用户指南.pdf

    9. **可扩展性**:基于yanf4j NIO框架,代码结构清晰,易于扩展和定制。 **使用指南** 开始使用XMemcached,首先需要构建MemcachedClient实例,如以下示例所示: ```java MemcachedClientBuilder builder = new ...

    Xmemcached用户指南

    - **基于Yanf4j框架**:XMemcached基于Java NIO框架Yanf4j构建,具有清晰的结构和良好的分层设计,易于扩展和定制。 #### 三、使用指南 **3.1 简单示例** 为了帮助读者更好地理解XMemcached的基本使用方法,下面...

    Xmemcached用户指南.docx

    9. **可扩展性**:基于yanf4j框架,XMemcached的架构清晰,易于扩展和维护。 **使用指南** 开始使用XMemcached,首先需要创建一个`XMemcachedClientBuilder`实例,并指定Memcached服务器的地址。例如,若服务器IP...

    xmemcached-1.2.4源码

    It's nio based (using my opensource nio framework :yanf4j), and was carefully tuned to get top performance. homepage: http://code.google.com/p/xmemcached/ downloads; ...

    淘宝gecko框架设计.pdf

    Gecko基于yanf4j(Yet another nio framework for java)构建,这是一个Reactor+Handler模式的NIO框架。框架的主要组件包括: - **Controller**:控制接口,负责启动、管理、停止框架,并与业务代码交互。 - **...

    《模式识别与人工智能》参与主办的第19期自动化前沿论坛召开.pdf

    [17]HUGS,YANF,CHANCH等人的工作涉及使用统一的三维形态模型进行面部识别。这些研究不仅展示了模式识别与人工智能领域的深度技术应用,也揭示了当前研究的发展趋势,例如三维模型构建、面部识别、图像编辑等。 此外...

    Yet Another News Fetcher-开源

    Yanf打开一个配置文件,对其进行读取,从其上的站点中获取新闻,然后将其放在类似于slashdot的网页中。 它支持Slashdot,Freshmeat。 32bitsonline,Segfault,Packetstorm,Linuxtelephony,Linuxtoday,Ufie,RDF...

    Foobar2000 简体中文版 全球最好的音乐播放器

    Foobar2000的开发者Peter Pawlowski持续进行软件更新和维护,不断引入新功能并修复问题。同时,有一个活跃的用户社区,提供插件开发和使用交流,使软件始终保持活力。 总结来说,Foobar2000凭借其卓越的音质、丰富...

    batik-all-1.8.jar

    免费分享。

Global site tag (gtag.js) - Google Analytics