nio/mina(四)客户端socket与mina服务端通信

 

客户端socket传对象给mina服务端暂时不通,可能跟下面传中文字符串有些类似.

应该和mina端过滤器的相关设置有关.

 

服务端:

1 MinaServer.java

    package com.nafio.server;  
      
    import java.io.IOException;  
    import java.net.InetSocketAddress;  
      
    import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;  
    import org.apache.mina.filter.codec.ProtocolCodecFilter;  
    import org.apache.mina.filter.codec.textline.TextLineCodecFactory;  
    import org.apache.mina.transport.socket.SocketAcceptor;  
    import org.apache.mina.transport.socket.nio.NioSocketAcceptor;  
      
    public class MinaServer {      
        private static MinaServer minaServer = null;  
        //创建一个非阻塞的Server端Socket  
        private SocketAcceptor acceptor = new NioSocketAcceptor();  
        //创建接收数据的过滤器  
        private DefaultIoFilterChainBuilder chain = acceptor.getFilterChain();          
        private int bindPort = 8888;  
          
        //单例  
        public static MinaServer getInstances() {      
            if (null == minaServer) {                 
                minaServer = new MinaServer();      
            }              
            return minaServer;      
        }          
        private MinaServer() {              
            //设定这个过滤器将按对象读取数据  
              
            //单例模式----------------------------------------  
    //      chain.addLast("myChin", new ProtocolCodecFilter(      
    //              new ObjectSerializationCodecFactory()));   
            //设定服务器端的消息处理器:一个MinaServerHandler对象,  
    //      acceptor.setHandler(ServerHandler.getInstances());     
              
              
            //非单例模式---------------------------------------  
            //接收文字  
            chain.addLast("myChin", new ProtocolCodecFilter(      
                    new TextLineCodecFactory()));   
            //接收对象  
    //      chain.addLast("myChin", new ProtocolCodecFilter(      
    //              new ObjectSerializationCodecFactory()));   
              
              
            acceptor.setHandler(new ServerHandler());  
            try {  
                //绑定端口,启动服务器  
                acceptor.bind(new InetSocketAddress(bindPort));  
                  
            } catch (IOException e) {                  
                e.printStackTrace();      
            }   
            System.out.println("服务端:监听端口--->" + bindPort);  
        }      
        public static void main(String[] args) throws Exception {      
            MinaServer.getInstances();   
            //new MinaServer();  
        }      
    }      

 

2 ServerHandler.java

    package com.nafio.server;  
      
    import org.apache.mina.core.filterchain.IoFilterAdapter;  
    import org.apache.mina.core.service.IoHandler;  
    import org.apache.mina.core.service.IoHandlerAdapter;  
    import org.apache.mina.core.session.IdleStatus;  
    import org.apache.mina.core.session.IoSession;  
      
    import com.nafio.obj.TransferObj;  
    //下面两种写法应该等同,不确定?  
    //public class ServerHandler extends IoHandlerAdapter {    
    public class ServerHandler extends IoFilterAdapter implements IoHandler {      
        private static ServerHandler samplMinaServerHandler = null;          
        public static ServerHandler getInstances() {  
            if (null == samplMinaServerHandler) {      
                samplMinaServerHandler = new ServerHandler();  
            }      
            return samplMinaServerHandler;          
        }      
        public ServerHandler() {      
        }      
        public void sessionOpened(IoSession session) throws Exception {  
            System.out.println("服务端:会话打开");  
        }      
        public void sessionClosed(IoSession session) {  
      
        }    
          
        public void messageReceived(IoSession session, Object message)throws Exception {  
            //接收字符串  
            String str = (String)message;  
            System.out.println("服务端:收到客户端发来的信息--->"+str);  
            //System.out.println("服务端:收到信息");  
            //接收对象  
    //      if (message instanceof TransferObj) {  
    //          TransferObj obj = (TransferObj) message;      
    //          System.out.println("服务端:收到客户端数据--->"+obj.getDate());+      
    //      }           
        }      
        public void exceptionCaught(IoSession arg0, Throwable arg1)throws Exception {          
        }          
        public void messageSent(IoSession arg0, Object arg1) throws Exception {      
              
        }      
        public void sessionCreated(IoSession arg0) throws Exception {  
            System.out.println("服务端:会话创建");  
        }          
        public void sessionIdle(IoSession arg0, IdleStatus arg1) throws Exception {   
              
        }      
    }    

 

socket客户端

SocketClient.java

    package com.nafio.socketclient;  
      
    import java.io.DataInputStream;  
    import java.io.DataOutputStream;  
    import java.io.IOException;  
    import java.io.ObjectOutputStream;  
    import java.net.Socket;  
    import com.nafio.obj.TransferObj;  
      
      
    public class SocketClient {  
          
        private Socket s;  
        private DataOutputStream out;  
        private DataInputStream in;  
        public SocketClient() throws IOException {  
        }  
      
      
        public static void main(String[] args) throws Exception {  
            SocketClient c = new SocketClient();  
            c.talk();  
        }  
    //  发送对象  
    //  ObjectOutputStream oos;  
    //  TransferObj obj;  
        public void sendMessage(Socket s) {  
            try {  
                  
                //socket传字符串  
                out = new DataOutputStream(s.getOutputStream());  
                byte[] bt="中文\n".getBytes();  
                out.write(bt);  
                out.writeBytes("nafio_date\n");  
                //out.writeUTF("中文\n");//by nafio这么写不行  
                  
                //socket传对象  
    //          oos = new ObjectOutputStream(s.getOutputStream());  
    //          obj=new TransferObj();  
    //          obj.setDate("socketDateToMina");  
    //          oos.writeObject(obj);  
    //          oos.flush();  
                  
            } catch (IOException e) {  
                e.printStackTrace();  
            }  
      
        }  
      
        public void receiveMessage(Socket s) {  
            try {  
                in = new DataInputStream(s.getInputStream());  
            } catch (Exception e) {  
                e.printStackTrace();  
            }  
        }  
      
        public void talk() throws Exception {  
            /*while (true)*/ {  
                try {  
                    //发送对象  
                    //oos.close();  
                    s = new Socket("localhost", 8888);  
                    System.out.println("客户端:发送信息");  
                    sendMessage(s);  
                    System.out.println("发送信息完毕!");  
                    //发字符串  
                    //receiveMessage(s);  
                    out.close();  
                    //in.close();  
                }  
                catch(Exception e){  
                    e.printStackTrace();  
                }  
                finally {  
                    try{  
                        if(s!=null)s.close();  //断开连接  
                    }catch (IOException e) {e.printStackTrace();}  
                }  
            }  
        }  
    }