亚洲区日韩区无码区,亚洲性色精品一区二区在线,亚洲a∨无码一区二区

jboss netty 框架小試

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 閱讀(3407) 評論(2) 編輯收藏所屬分類: Java 、java Net


只有注冊用戶登錄后才能發(fā)表評論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關(guān)文章: PP代碼生成器(四) 使用解決方案生成代碼 PP代碼生成器(三) 設(shè)計freemarker模板, 創(chuàng)建解決方案 PP代碼生成器(二) 解決方案, 生成任務(wù), 輔助設(shè)計面板 PP代碼生成器(一) 簡介, 下載, 運行 PP持久層代碼生成器 eclipse maven 平衡二叉樹,java實現(xiàn) 數(shù)據(jù)結(jié)構(gòu)復(fù)習(xí) 萬能分頁標(biāo)簽優(yōu)化Servlet配置為web.xml瘦身

夢幻之旅

公告

常用鏈接

留言簿(21)

隨筆分類(644)

隨筆檔案(669)

文章檔案(6)

最新隨筆

積分與排名

最新評論

閱讀排行榜

評論排行榜

評論