日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
JavaSocket實(shí)戰(zhàn)之四：傳輸壓縮對(duì)象

上一篇文章說到了用Java Socket來傳輸對(duì)象，但是在有些情況下比如網(wǎng)絡(luò)環(huán)境不好或者對(duì)象比較大的情況下需要把數(shù)據(jù)對(duì)象進(jìn)行壓縮然后在傳輸，此時(shí)就需要壓縮這些對(duì)象流，此時(shí)就可以GZIPInputStream和GZIPOutputStream來處理一下socket的InputStream和OutputStream。

創(chuàng)新互聯(lián)建站長(zhǎng)期為千余家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為吉安企業(yè)提供專業(yè)的成都網(wǎng)站設(shè)計(jì)、做網(wǎng)站，吉安網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

仍然需要一個(gè)實(shí)現(xiàn)了java.io.Serializable接口的簡(jiǎn)單Java對(duì)象：

 
 
 
    
  
  
  
  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.

***測(cè)試上面的代碼，首先運(yùn)行Server類，然后運(yùn)行Client類，就可以分別在Server端和Client端控制臺(tái)看到接收到的User對(duì)象實(shí)例了。

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


本文名稱：JavaSocket實(shí)戰(zhàn)之四：傳輸壓縮對(duì)象
當(dāng)前路徑：http://m.5511xx.com/article/dpdpdsi.html