java线程之三 对象传输

之前例子中已经介绍了如何使用socket进行信息的传输，及其如何进行多客户端的通信。

但是实际开发中，我们不可能只传输简单的基础类型的数据。更多的是要传输一个对象,或则信息包。

因此今天的场合要用到ObjectInputStream/ObjectOutputStream对象。

要传输对象，我们首先定义一个对象类User

public class User implements Serializable{
    
    
    /**
     * java.io.InvalidClassException: com.lwx.bean.User; local class incompatible: stream classdesc serialVersionUID = 1, local class serialVersionUID = 8089718401965834129

     */
    private static final long serialVersionUID = 8089718401965834129L;
    public User() {

    }

    public User(int id, String name) {
        this.id = id;
        this.name = name;
    }

    private int id;
    private String name;
    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

}

注意的是，对象必须进行实例化。同时生成serialVersionUID。

接着我们创建服务端程序

服务端代码

/**
 * @author  draem0507@gmail.com
 * @TODO    java线程开发之三 对象传输
 * @version 1.0
 * @date 2013-5-7下午09:22:45    
 * @blgos myblog:http://www.cnblogs.com/draem0507
 */

public class ServerTest {
    private ServerSocket serverSocket;

    

    public ServerTest() {
        try {
            serverSocket = new ServerSocket(10000);
            // 开启无限循环 创建每个客户端的socket线程
            while (true) {
                Socket socket = serverSocket.accept();
                new ReceiveSocket(socket).start();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    public static void main(String[] args) {
        new ServerTest();

    }

    private class ReceiveSocket extends Thread {
        private Socket socket;

        public ReceiveSocket(Socket socket) {
            this.socket = socket;
        }

        private ObjectInputStream reader;
        private ObjectOutputStream writer;

        @Override
        public void run() {

            try {
                reader=new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));
                //writer=new ObjectOutputStream(socket.getOutputStream());
                // 开启无限循环 监控消息
                
                    //java.io.EOFException
                Object obj=    reader.readObject();
                    if(obj!=null)
                    {
                        User user =(User)obj;
                        System.out.println("id=="+user.getId()+"\tname=="+user.getName());
                    }
                //    while (true) {}

            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally {
                if (null != reader) {
                    try {
                        reader.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                if (null != writer) {
                    try {
                        reader.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                try {
                    socket.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }

        }

    }

}

客户端代码

public class ClientTest {
    
    
    public static void main(String[] args) throws Exception {
        
        Socket socket = new Socket("localhost", 10000);
        //ObjectInputStream in=new ObjectInputStream(socket.getInputStream());
        ObjectOutputStream out=new ObjectOutputStream(socket.getOutputStream());
        
        
                User user =new User();
                user.setId(1);
                user.setName("lwx_"+1);
                out.writeObject(user);
                out.flush();
    
            
        socket.close();
        
        
    }
}

老规矩，先运行服务端，在执行客户端。这里跟之前相对，并没有实现服务端往客户端发送信息，要测试的朋友自己加代码，a piece of cake.

在看csdn的时候，看到有人写道关于压缩传输的介绍，就顺便把代码贴上来。

压缩服务端代码

//压缩对象的方式传输
public class MyServer {

    private final static Logger logger = Logger.getLogger(MyServer.class.getName());
    
    public static void main(String[] args) throws IOException {
        ServerSocket server = new ServerSocket(10000);

        while (true) {
            Socket socket = server.accept();
            socket.setSoTimeout(10 * 1000);
            invoke(socket);
        }
    }

    private static void invoke(final Socket socket) throws IOException {
        new Thread(new Runnable() {
            public void run() {
                GZIPInputStream gzipis = null;
                ObjectInputStream ois = null;
                GZIPOutputStream gzipos = null;
                ObjectOutputStream oos = null;
                
                try {
                    gzipis = new GZIPInputStream(socket.getInputStream());
                    ois = new ObjectInputStream(gzipis);
                    gzipos = new GZIPOutputStream(socket.getOutputStream());
                    oos = new ObjectOutputStream(gzipos);

                    Object obj = ois.readObject();
                    User user = (User)obj;
                    System.out.println("user: " + user.getId() + "/" + user.getName());

                    user.setName(user.getName() + "_new");
                    user.setId(user.getId() *2);

                    oos.writeObject(user);
                    oos.flush();
                    gzipos.finish();
                } catch (IOException ex) {
                    logger.log(Level.SEVERE, null, ex);
                } catch(ClassNotFoundException ex) {
                    logger.log(Level.SEVERE, null, ex);
                } finally {
                    try {
                        ois.close();
                    } catch(Exception ex) {}
                    try {
                        oos.close();
                    } catch(Exception ex) {}
                    try {
                        socket.close();
                    } catch(Exception ex) {}
                }
            }
        }).start();
    }
}

压缩客户端代码

public class MyClient {
    
    private final static Logger logger = Logger.getLogger(MyClient.class.getName());
    
    public static void main(String[] args) throws Exception {
        for (int i = 0; i < 10; i++) {
            Socket socket = null;
            GZIPOutputStream gzipos = null;
            ObjectOutputStream oos = null;
            GZIPInputStream gzipis = null;
            ObjectInputStream ois = null;
            
            try {
                socket = new Socket();
                SocketAddress socketAddress = new InetSocketAddress("localhost", 10000); 
                socket.connect(socketAddress, 10 * 1000);
                socket.setSoTimeout(10 * 1000);
                
                gzipos = new GZIPOutputStream(socket.getOutputStream());
                oos = new ObjectOutputStream(gzipos);
                User user = new User(  i, "lwx_" + i);
                oos.writeObject(user);
                oos.flush();
                gzipos.finish();
                
                gzipis = new GZIPInputStream(socket.getInputStream());
                ois = new ObjectInputStream(gzipis);
                Object obj = ois.readObject();
                if (obj != null) {
                    user = (User)obj;
                    System.out.println("user: " + user.getId() + "/" + user.getName());
                }
            } catch(IOException ex) {
                logger.log(Level.SEVERE, null, ex);
            } finally {
                try {
                    ois.close();
                } catch(Exception ex) {}
                try {
                    oos.close();
                } catch(Exception ex) {}
                try {
                    socket.close();
                } catch(Exception ex) {}
            }
        }
    }
}