<rt id="bn8ez"></rt>
<label id="bn8ez"></label>
  • 

    • <span id="bn8ez"></span>
    

    <label id="bn8ez"><meter id="bn8ez"></meter></label>
    

    
    

    




    







												


        

    
	

    
	
    
		
    
			
				
    夢幻之旅
    
				
    DEBUG - 天道酬勤
    
			    		
		
    
	
    

    

    
	
    
		
    
			
 
 ::
首頁 ::
新隨筆 ::
聯(lián)系 ::
聚合
 ::
管理 ::


			
			
				

    
	
    
		
    
			
			
			
				 
				671 
				隨筆 ::
				6 文章
				::
				256 評論
				::
				0 Trackbacks
			
		
    
	
    

    

			    		
		
    
	
    

    


    


    
	
					

    
	
	
	
    
		
    1.server 

    package example.helloword.server;

    import java.net.InetSocketAddress;
    import java.util.concurrent.Executors;

    import org.jboss.netty.bootstrap.ServerBootstrap;
    import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory;

    import example.helloword.NetConstant;

    public class Server
    {
            private static Server server = new Server();
        
            private ServerBootstrap bootstrap;
        
            private Server()
            {}
        
            public static Server getInstance()
            {
                return server;
        }
        
            public void start()
            {
            bootstrap     = new ServerBootstrap(new NioServerSocketChannelFactory(
                    Executors.newCachedThreadPool(), Executors
                            .newCachedThreadPool()));
            bootstrap.setPipelineFactory(    new ServerPipelineFactory());
            bootstrap.bind(    new InetSocketAddress(NetConstant.server_port));
        }
        
            public void stop()
            {
            bootstrap.releaseExternalResources();
        }
        
            public static void main(String[] args)
            {
            Server server     = Server.getInstance();
            server.start();
        }
    }
    2.ServerPipelineFactory
    

    package example.helloword.server;

    import static org.jboss.netty.channel.Channels.pipeline;

    import org.jboss.netty.channel.ChannelPipeline;
    import org.jboss.netty.channel.ChannelPipelineFactory;
    import org.jboss.netty.handler.codec.string.StringDecoder;
    import org.jboss.netty.handler.codec.string.StringEncoder;

    public class ServerPipelineFactory implements ChannelPipelineFactory
    {
            public ChannelPipeline getPipeline() throws Exception
            {
            ChannelPipeline pipleline     = pipeline();
            pipleline.addLast(    "encode", new StringEncoder());
            pipleline.addLast(    "decode", new StringDecoder());
            pipleline.addLast(    "handler", new ServerHandler());
                return pipleline;
        }
    }
    3.handle
    

    package example.helloword.server;

    import org.jboss.netty.channel.ChannelHandlerContext;
    import org.jboss.netty.channel.ExceptionEvent;
    import org.jboss.netty.channel.MessageEvent;
    import org.jboss.netty.channel.SimpleChannelUpstreamHandler;

    public class ServerHandler extends SimpleChannelUpstreamHandler
    {
            public void messageReceived(ChannelHandlerContext ctx, MessageEvent e)
                    throws Exception
            {
            System.out.println(    "recive message,message content:" + e.getMessage());
            e.getChannel().write(    "byte");
            
        }
        
            public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e)
                    throws Exception
            {
            e.getChannel().close();
        }
    }
    clinet:
    

    package example.helloword.client22;

    import static org.jboss.netty.channel.Channels.pipeline;

    import org.jboss.netty.channel.ChannelPipeline;
    import org.jboss.netty.channel.ChannelPipelineFactory;
    import org.jboss.netty.handler.codec.frame.LengthFieldBasedFrameDecoder;
    import org.jboss.netty.handler.codec.frame.LengthFieldPrepender;
    import org.jboss.netty.handler.codec.string.StringDecoder;
    import org.jboss.netty.handler.codec.string.StringEncoder;

    public class ClientPipelineFactory implements ChannelPipelineFactory
    {
            public ChannelPipeline getPipeline() throws Exception
            {
            ChannelPipeline pipleline     = pipeline();  
            pipleline.addLast(    "frameDecoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4));  
            pipleline.addLast(    "frameEncode", new LengthFieldPrepender(4, false));
            pipleline.addLast(    "encode", new StringEncoder());  
            pipleline.addLast(    "decode", new StringDecoder());  
            pipleline.addLast(    "handler", new ClinetHandler());  
                return pipleline;  
        }
    }
    clientpool:
    

    package example.helloword.client22;

    import java.net.InetSocketAddress;
    import java.util.concurrent.Executors;

    import org.jboss.netty.bootstrap.ClientBootstrap;
    import org.jboss.netty.channel.ChannelFuture;
    import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory;

    import example.helloword.NetConstant;
    import example.helloword.client2.ClientPipelineFactory;

    public class ClientPool
    {
            public static ClientPool clientPool = new ClientPool();
        
            private ClientBootstrap bootstrap;
        
            private ClientPool()
            {
            bootstrap     = new ClientBootstrap(new NioClientSocketChannelFactory(
                    Executors.newCachedThreadPool(), Executors
                            .newCachedThreadPool()));
            
            bootstrap.setPipelineFactory(    new ClientPipelineFactory());
            bootstrap.setOption(    "tcpNoDelay", true);
            bootstrap.setOption(    "keepAlive", true);
        }
        
            public static ClientPool getInstance()
            {
                return clientPool;
        }
        
            public void getChannelFuture(String host, int port, String message)
            {
            ChannelFuture future     = bootstrap.connect(new InetSocketAddress(host,
                    NetConstant.server_port));
            future.awaitUninterruptibly();
                if (!future.isSuccess())
                {
                future.getCause().printStackTrace();
                future.getChannel().getCloseFuture().awaitUninterruptibly(); 
                    return;
            }
            future.getChannel().write(message);
        }
        
            public static void main(String[] args) throws InterruptedException
            {
                for (int i = 0; i < 1000; i++)
                {
                ClientPool.getInstance().getChannelFuture(    "127.0.0.1", 0,
                            "test" + i);
                Thread.sleep(    1000 * 3);
            }
        }
    }
     
	
    
	
	
    
		posted on 2011-08-30 13:07 HUIKK 閱讀(3408) 評論(2)  編輯  收藏  所屬分類: Java 、java Net 
	
    

    







    
	    
    


    

    
	
    評論
    
		
		
				
    			
					
    
						# re: jboss netty 框架小試
							
								2013-11-04 15:25
							
						kunjie
					
    
					
    
						LZ,這文章，一點文字說明都沒，沒有多大實用意義  回復(fù)  更多評論
						
    
						  
					
    
				
    
				
    
			
				
    			
					
    
						# re: jboss netty 框架小試[未登錄]
							
								2014-01-02 14:47
							
						123
					
    
					
    
						tell us about what you think and code less, plz.  回復(fù)  更多評論
						
    
						  
					
    
				
    
				
    
			

    




    








    

				

    




    







    
        
	



主站蜘蛛池模板：
中文在线免费视频|
亚洲人成网站在线观看播放|
久久国产乱子免费精品|
国产成人精品日本亚洲语音
|
久久人午夜亚洲精品无码区|
亚洲美女激情视频|
亚洲精品无码MV在线观看|
免费一级毛片不卡在线播放|
猫咪社区免费资源在线观看|
99在线观看免费视频|
h视频免费高清在线观看|
亚洲国产成人精品无码区二本|
亚洲无限乱码一二三四区|
亚洲成AV人片在WWW色猫咪|
亚洲日韩精品无码专区网站|
又粗又大又长又爽免费视频|
天天操夜夜操免费视频|
永久免费的网站在线观看|
最近中文字幕电影大全免费版
|
在线观看永久免费视频网站|
91免费资源网站入口|
日韩不卡免费视频|
亚洲大片免费观看|
四虎成人精品永久免费AV|
最近的2019免费中文字幕|
中文在线观看免费网站|
97超高清在线观看免费视频|
黄色视频在线免费观看|
中文字幕手机在线免费看电影
|
免费在线观看一级毛片|
国产成人免费网站在线观看|
午夜男人一级毛片免费|
精品免费国产一区二区三区|
免费观看大片毛片|
精品久久久久久久免费加勒比|
爽爽日本在线视频免费|
日日操夜夜操免费视频|
免费中文字幕一级毛片|
亚洲精品麻豆av|
亚洲熟妇无码另类久久久|
亚洲国产三级在线观看|