ssm框架整合及所有jar包

package com.goldcard.platform.netty; import static org.jboss.netty.channel.Channels.pipeline; 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.ChannelPipeline; import org.jboss.netty.channel.ChannelPipelineFactory; import org.jboss.netty.channel.Channels; import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory; import org.jboss.netty.handler.codec.serialization.ClassResolvers; import org.jboss.netty.handler.codec.serialization.ObjectDecoder; import org.jboss.netty.handler.codec.serialization.ObjectEncoder; import org.jboss.netty.handler.codec.string.StringDecoder; import org.jboss.netty.handler.codec.string.StringEncoder; import com.goldcard.platform.entity.Command; /** * 启动一个client线程，用来间歇性的发送消息 * * @author Ransom */ public class ClientThread implements Runnable { private ChannelFuture future; public ChannelFuture getFuture() { return future; } public void setFuture(ChannelFuture future) { this.future = future; } public void run() { initClient(); } public void initClient() { /* * 实例化一个客户端Bootstrap实例， NioClientSocketChannelFactory是Netty默认提供的。 两个参数，一个是boss的线程池，一个是worker执行的线程池。 * 两个线程池都使用了java.util.concurrent.Executors中的线程池来创建。 */ ClientBootstrap bootstrap = new ClientBootstrap( new NioClientSocketChannelFactory( Executors.newCachedThreadPool(), Executors.newCachedThreadPool())); /* * 设置piplineFactory, 顾名思义，就是产生默认的pipline。 pipline的实例是DefaultChannelPipeline 提供了链式的事件通讯机制 */ bootstrap.setPipelineFactory(new ChannelPipelineFactory() { /* * (non-Javadoc) * @see org.jboss.netty.channel.ChannelPipelineFactory#getPipeline() */ public ChannelPipeline getPipeline() throws Exception { /* * 在DefaultChannelPipeline的过滤器 链中实现了 encode 、decode、handler 其中encode实现自ChannelDownstreamHandler接口 * decode、Handler实现自ChannelUpstreamHandler接口 也就说明了在client发送消息的时候，默认按照顺序会先调用decode * 在client接收到响应的时候，会按照顺序调用encode和Handler。 后面会有文章专门将ChannelDownstreamHandler和ChannelUpstreamHandler的调用顺序。 */ ChannelPipeline pipleline = pipeline(); pipleline = Channels.pipeline(new ObjectEncoder(), new ObjectDecoder(ClassResolvers.cacheDisabled(this.getClass().getClassLoader())), new ClientObjectHandler()); // pipleline.addLast("encode", new StringEncoder()); // pipleline.addLast("decode", new StringDecoder()); // pipleline.addLast("handler", new Handler()); return pipleline; } }); /* * 与127.0.0.1建立长连接。 */ future = bootstrap.connect(new InetSocketAddress("localhost", 8080)); System.out.println("链接已建立，地址为：localhost:8080"); } /** * 发送消息至server */ public void sendMsg() { if (future == null) return; String s = "Hello Server!"; future.getChannel().write(s); } public void sendObjMsg() { Command command = new Command(); command.setActionName("Hello action."); future.getChannel().write(command); } }