apache中的高性能网络服务框架Mina

转帖|其它|编辑:郝浩|2009-03-02 10:34:04.000|阅读 1327 次

概述:因为想做网络flash游戏(想开始做个简单的五子棋),希望可以高效的开发,因为应用群不会超过并发200个点,所以性能不是优先考虑,同时又恰好看到了mina,故事从这里开始......

# 界面/图表报表/文档/IDE等千款热门软控件火热销售中 >>

  Mina是个apache的一个子项,它把tcp udp pipe等做了很好的封装,同时我不考虑用c写是因为以后给别人不好维护,因为现在学c的人实在越来越少了,但是需要性能的网络服务还真得用C,又费话了一段,下面具体介绍我刚了解的Mina。

  因为adobe flash or flex只支持tcp client,所以我测试了Mina的tcp server部分,看一段代码先:

  import java.io.IOException;

  import java.net.InetSocketAddress;

  import java.nio.charset.Charset;

  import org.apache.mina.common.ByteBuffer;

  import org.apache.mina.common.IoAcceptor;

  import org.apache.mina.common.SimpleByteBufferAllocator;

  import org.apache.mina.filter.LoggingFilter;

  import org.apache.mina.filter.codec.ProtocolCodecFilter;

  import org.apache.mina.filter.codec.textline.TextLineCodecFactory;

  import org.apache.mina.transport.socket.nio.SocketAcceptor;

  import org.apache.mina.transport.socket.nio.SocketAcceptorConfig;

  public class test {

  /**

  * @param args

  */

  private static final int PORT = 9000;

  public static void main(String[] args) throws IOException {

  ByteBuffer.setUseDirectBuffers(false);/*设置内存获取方式*/

  ByteBuffer.setAllocator(new SimpleByteBufferAllocator());

  IoAcceptor acceptor = new SocketAcceptor();/*socket接受服务*/

  acceptor.bind( new InetSocketAddress(PORT), new TimeServerHandler());/*bind tcp的服务,到这里有用的好像就两行就搞定了,很简单,这样服务就起来了,呵呵*/

  System.out.println("MINA Time server started.");

  }

  }
 
  TimeServerHandler这个部分是实现tcp server处理的部分,以下描述:(为什么起这个名字,因为整个代码我通过网站快速向导做的,没有修改,原来向导是实现了一个时间询问服务)

  import java.util.Date;

  import org.apache.mina.common.IdleStatus;

  import org.apache.mina.common.IoHandlerAdapter;

  import org.apache.mina.common.IoSession;

  import org.apache.mina.common.TransportType;

  import org.apache.mina.transport.socket.nio.SocketSessionConfig;

  import org.apache.mina.common.ByteBuffer;

  public class TimeServerHandler extends IoHandlerAdapter {

  /*当tcp client发生异常断开时触发*/

  public void exceptionCaught(IoSession session, Throwable t) throws Exception {

  t.printStackTrace();

  session.close();

  }

  /*当有数据来时触发*/

  public void messageReceived(IoSession session, Object msg) throws Exception {

  /*接受数据,并且打印成hex*/

  ByteBuffer get = (ByteBuffer)msg;

  System.out.println("Rec:" + get.getHexDump());

  /*反馈数据,一个a*/

  ByteBuffer bb = ByteBuffer.allocate(10);

  bb.asCharBuffer().append('a');

  session.write( bb);

  System.out.println("Message written...");

  }

  /*当连接建立时触发*/

  public void sessionCreated(IoSession session) throws Exception {

  System.out.println("Session created...");

  if( session.getTransportType() == TransportType.SOCKET )

  ((SocketSessionConfig) session.getConfig() ).setReceiveBufferSize( 2048 );

  session.setIdleTime( IdleStatus.BOTH_IDLE, 10 );

  }

  }


标签:

本站文章除注明转载外,均为本站原创或翻译。欢迎任何形式的转载,但请务必注明出处、不得修改原文相关链接,如果存在内容上的异议请邮件反馈至chenjj@evget.com

文章转载自:IT专家网

为你推荐

  • 推荐视频
  • 推荐活动
  • 推荐产品
  • 推荐文章
  • 慧都慧问
扫码咨询


添加微信 立即咨询

电话咨询

客服热线
023-68661681

TOP