JavaSocket实战之四：传输压缩对象

上一篇文章说到了用Java Socket来传输对象，但是在有些情况下比如网络环境不好或者对象比较大的情况下需要把数据对象进行压缩然后在传输，此时就需要压缩这些对象流，此时就可以GZIPInputStream和GZIPOutputStream来处理一下socket的InputStream和OutputStream。

创新互联建站长期为千余家客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为吉安企业提供专业的成都网站设计、做网站，吉安网站改版等技术服务。拥有十载丰富建站经验和众多成功案例,为您定制开发。

仍然需要一个实现了java.io.Serializable接口的简单Java对象：

 
 
 
    
  
  
  
  1. package com.googlecode.garbagecan.test.socket.sample4;  
    2.   
  
  
  2.  
    3.   
  
  
  3. public class User implements java.io.Serializable {  
    4.   
  
  
  4.     private static final long serialVersionUID = 1L;  
    5.   
  
  
  5.     private String name;  
    6.   
  
  
  6.     private String password;  
    7.   
  
  
  7.  
    8.   
  
  
  8.     public User() {  
    9.   
  
  
  9.           
    10.   
  
  
  10.     }  
    11.   
  
  
  11.       
    12.   
  
  
  12.     public User(String name, String password) {  
    13.   
  
  
  13.         this.name = name;  
    14.   
  
  
  14.         this.password = password;  
    15.   
  
  
  15.     }  
    16.   
  
  
  16.       
    17.   
  
  
  17.     public String getName() {  
    18.   
  
  
  18.         return name;  
    19.   
  
  
  19.     }  
    20.   
  
  
  20.  
    21.   
  
  
  21.     public void setName(String name) {  
    22.   
  
  
  22.         this.name = name;  
    23.   
  
  
  23.     }  
    24.   
  
  
  24.  
    25.   
  
  
  25.     public String getPassword() {  
    26.   
  
  
  26.         return password;  
    27.   
  
  
  27.     }  
    28.   
  
  
  28.  
    29.   
  
  
  29.     public void setPassword(String password) {  
    30.   
  
  
  30.         this.password = password;  
    31.   
  
  
  31.     }  
    32.   
  
  
  32.       
    33.   
  
  
  33. } 
    34.

在Server端使用，socket的InputStream首先被包装成GZIPInputStream，然后又被包装成ObjectInputStream，而socket的OutputStream首先被包装成GZIPOutputStream，然后又被包装成ObjectOutputStream，如下：

 
 
 
    
  
  
  
  1. package com.googlecode.garbagecan.test.socket.sample4;  
    2.   
  
  
  2.  
    3.   
  
  
  3. import java.io.IOException;  
    4.   
  
  
  4. import java.io.ObjectInputStream;  
    5.   
  
  
  5. import java.io.ObjectOutputStream;  
    6.   
  
  
  6. import java.net.ServerSocket;  
    7.   
  
  
  7. import java.net.Socket;  
    8.   
  
  
  8. import java.util.logging.Level;  
    9.   
  
  
  9. import java.util.logging.Logger;  
    10.   
  
  
  10. import java.util.zip.GZIPInputStream;  
    11.   
  
  
  11. import java.util.zip.GZIPOutputStream;  
    12.   
  
  
  12.  
    13.   
  
  
  13. public class MyServer {  
    14.   
  
  
  14.  
    15.   
  
  
  15.     private final static Logger logger = Logger.getLogger(MyServer.class.getName());  
    16.   
  
  
  16.       
    17.   
  
  
  17.     public static void main(String[] args) throws IOException {  
    18.   
  
  
  18.         ServerSocket server = new ServerSocket(10000);  
    19.   
  
  
  19.  
    20.   
  
  
  20.         while (true) {  
    21.   
  
  
  21.             Socket socket = server.accept();  
    22.   
  
  
  22.             socket.setSoTimeout(10 * 1000);  
    23.   
  
  
  23.             invoke(socket);  
    24.   
  
  
  24.         }  
    25.   
  
  
  25.     }  
    26.   
  
  
  26.  
    27.   
  
  
  27.     private static void invoke(final Socket socket) throws IOException {  
    28.   
  
  
  28.         new Thread(new Runnable() {  
    29.   
  
  
  29.             public void run() {  
    30.   
  
  
  30.                 GZIPInputStream gzipis = null;  
    31.   
  
  
  31.                 ObjectInputStream ois = null;  
    32.   
  
  
  32.                 GZIPOutputStream gzipos = null;  
    33.   
  
  
  33.                 ObjectOutputStream oos = null;  
    34.   
  
  
  34.                   
    35.   
  
  
  35.                 try {  
    36.   
  
  
  36.                     gzipis = new GZIPInputStream(socket.getInputStream());  
    37.   
  
  
  37.                     ois = new ObjectInputStream(gzipis);  
    38.   
  
  
  38.                     gzipos = new GZIPOutputStream(socket.getOutputStream());  
    39.   
  
  
  39.                     oos = new ObjectOutputStream(gzipos);  
    40.   
  
  
  40.  
    41.   
  
  
  41.                     Object obj = ois.readObject();  
    42.   
  
  
  42.                     User user = (User)obj;  
    43.   
  
  
  43.                     System.out.println("user: " + user.getName() + "/" + user.getPassword());  
    44.   
  
  
  44.  
    45.   
  
  
  45.                     user.setName(user.getName() + "_new");  
    46.   
  
  
  46.                     user.setPassword(user.getPassword() + "_new");  
    47.   
  
  
  47.  
    48.   
  
  
  48.                     oos.writeObject(user);  
    49.   
  
  
  49.                     oos.flush();  
    50.   
  
  
  50.                     gzipos.finish();  
    51.   
  
  
  51.                 } catch (IOException ex) {  
    52.   
  
  
  52.                     logger.log(Level.SEVERE, null, ex);  
    53.   
  
  
  53.                 } catch(ClassNotFoundException ex) {  
    54.   
  
  
  54.                     logger.log(Level.SEVERE, null, ex);  
    55.   
  
  
  55.                 } finally {  
    56.   
  
  
  56.                     try {  
    57.   
  
  
  57.                         ois.close();  
    58.   
  
  
  58.                     } catch(Exception ex) {}  
    59.   
  
  
  59.                     try {  
    60.   
  
  
  60.                         oos.close();  
    61.   
  
  
  61.                     } catch(Exception ex) {}  
    62.   
  
  
  62.                     try {  
    63.   
  
  
  63.                         socket.close();  
    64.   
  
  
  64.                     } catch(Exception ex) {}  
    65.   
  
  
  65.                 }  
    66.   
  
  
  66.             }  
    67.   
  
  
  67.         }).start();  
    68.   
  
  
  68.     }  
    69.   
  
  
  69. } 
    70.

Client也和Server端类似，同样要不socket的XXXStream包装成GZIPXXXStream，然后再包装成ObjectXXXStream，如下：

 
 
 
    
  
  
  
  1. package com.googlecode.garbagecan.test.socket.sample4;  
    2.   
  
  
  2.  
    3.   
  
  
  3. import java.io.IOException;  
    4.   
  
  
  4. import java.io.ObjectInputStream;  
    5.   
  
  
  5. import java.io.ObjectOutputStream;  
    6.   
  
  
  6. import java.net.InetSocketAddress;  
    7.   
  
  
  7. import java.net.Socket;  
    8.   
  
  
  8. import java.net.SocketAddress;  
    9.   
  
  
  9. import java.util.logging.Level;  
    10.   
  
  
  10. import java.util.logging.Logger;  
    11.   
  
  
  11. import java.util.zip.GZIPInputStream;  
    12.   
  
  
  12. import java.util.zip.GZIPOutputStream;  
    13.   
  
  
  13.  
    14.   
  
  
  14. public class MyClient {  
    15.   
  
  
  15.       
    16.   
  
  
  16.     private final static Logger logger = Logger.getLogger(MyClient.class.getName());  
    17.   
  
  
  17.       
    18.   
  
  
  18.     public static void main(String[] args) throws Exception {  
    19.   
  
  
  19.         for (int i = 0; i < 10; i++) {  
    20.   
  
  
  20.             Socket socket = null;  
    21.   
  
  
  21.             GZIPOutputStream gzipos = null;  
    22.   
  
  
  22.             ObjectOutputStream oos = null;  
    23.   
  
  
  23.             GZIPInputStream gzipis = null;  
    24.   
  
  
  24.             ObjectInputStream ois = null;  
    25.   
  
  
  25.               
    26.   
  
  
  26.             try {  
    27.   
  
  
  27.                 socket = new Socket();  
    28.   
  
  
  28.                 SocketAddress socketAddress = new InetSocketAddress("localhost", 10000);   
    29.   
  
  
  29.                 socket.connect(socketAddress, 10 * 1000);  
    30.   
  
  
  30.                 socket.setSoTimeout(10 * 1000);  
    31.   
  
  
  31.                   
    32.   
  
  
  32.                 gzipos = new GZIPOutputStream(socket.getOutputStream());  
    33.   
  
  
  33.                 oos = new ObjectOutputStream(gzipos);  
    34.   
  
  
  34.                 User user = new User("user_" + i, "password_" + i);  
    35.   
  
  
  35.                 oos.writeObject(user);  
    36.   
  
  
  36.                 oos.flush();  
    37.   
  
  
  37.                 gzipos.finish();  
    38.   
  
  
  38.                   
    39.   
  
  
  39.                 gzipis = new GZIPInputStream(socket.getInputStream());  
    40.   
  
  
  40.                 ois = new ObjectInputStream(gzipis);  
    41.   
  
  
  41.                 Object obj = ois.readObject();  
    42.   
  
  
  42.                 if (obj != null) {  
    43.   
  
  
  43.                     user = (User)obj;  
    44.   
  
  
  44.                     System.out.println("user: " + user.getName() + "/" + user.getPassword());  
    45.   
  
  
  45.                 }  
    46.   
  
  
  46.             } catch(IOException ex) {  
    47.   
  
  
  47.                 logger.log(Level.SEVERE, null, ex);  
    48.   
  
  
  48.             }  
    49.   
  
  
  49.             try {  
    50.   
  
  
  50.                 oos.close();  
    51.   
  
  
  51.             } catch (IOException e) {  
    52.   
  
  
  52.             }  
    53.   
  
  
  53.             try {  
    54.   
  
  
  54.                 ois.close();  
    55.   
  
  
  55.             } catch (IOException e) {  
    56.   
  
  
  56.             }  
    57.   
  
  
  57.             try {  
    58.   
  
  
  58.                 socket.close();  
    59.   
  
  
  59.             } catch (IOException e) {  
    60.   
  
  
  60.             }  
    61.   
  
  
  61.         }  
    62.   
  
  
  62.     }  
    63.   
  
  
  63. } 
    64.

***测试上面的代码，首先运行Server类，然后运行Client类，就可以分别在Server端和Client端控制台看到接收到的User对象实例了。

原文链接：http://blog.csdn.net/kongxx/article/details/7259834

本文标题：JavaSocket实战之四：传输压缩对象
文章来源：http://www.csdahua.cn/qtweb/news20/480570.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

网站排名知识

分类信息网站

防护网厂　　 　网站定制　　 　升施印刷　　 　主动防护网　　 　网站开发　　 　网上商城开发　　 　电商网站建设　　 　胜锦安防科技　　 　成都服务器托管　　 　成都网站维护　　 　抖音代运营　　 　led背发光字　　 　无边发光字　　 　成都做网站　　 　雅安网站建设　　 　绵竹网站建设　　 　成都免费做网站公司　　 　四川锦华橡塑　　 　成都广告设计公司　　 　成都网站设计