辰东完美世界有声小说,yy玄幻小说排行榜完本,盗墓笔记小说txt下载

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案

JavaSocket實戰(zhàn)之三：傳輸對象

前面兩篇文章介紹了怎樣建立Java Socket通信，這一篇說一下怎樣使用Java Socket來傳輸對象。

創(chuàng)新互聯(lián)公司成立十年來，這條路我們正越走越好，積累了技術與客戶資源，形成了良好的口碑。為客戶提供網(wǎng)站制作、網(wǎng)站建設、網(wǎng)站策劃、網(wǎng)頁設計、域名注冊、網(wǎng)絡營銷、VI設計、網(wǎng)站改版、漏洞修補等服務。網(wǎng)站是否美觀、功能強大、用戶體驗好、性價比高、打開快等等，這些對于網(wǎng)站建設都非常重要，創(chuàng)新互聯(lián)公司通過對建站技術性的掌握、對創(chuàng)意設計的研究為客戶提供一站式互聯(lián)網(wǎng)解決方案，攜手廣大客戶，共同發(fā)展進步。

首先需要一個普通的對象類，由于需要序列化這個對象以便在網(wǎng)絡上傳輸，所以實現(xiàn)java.io.Serializable接口就是必不可少的了，如下：

 
 
 
  
  
  package com.googlecode.garbagecan.test.socket.sample3;    
  
     
  
  public class User implements java.io.Serializable {    
  
      private static final long serialVersionUID = 1L;    
  
      private String name;    
  
      private String password;    
  
     
  
      public User() {    
  
              
  
      }    
  
          
  
      public User(String name, String password) {    
  
          this.name = name;    
  
          this.password = password;    
  
      }    
  
          
  
      public String getName() {    
  
          return name;    
  
      }    
  
     
  
      public void setName(String name) {    
  
          this.name = name;    
  
      }    
  
     
  
      public String getPassword() {    
  
          return password;    
  
      }    
  
     
  
      public void setPassword(String password) {    
  
          this.password = password;    
  
      }    
  
  }

對于Server端的代碼，代碼中分別使用了ObjectInputStream和ObjectOutputStream來接收和發(fā)送socket中的InputStream和OutputStream，然后轉換成Java對象，如下：

 
 
 
  
  
  package com.googlecode.garbagecan.test.socket.sample3;    
  
     
  
  import java.io.*;    
  
  import java.net.ServerSocket;    
  
  import java.net.Socket;    
  
  import java.util.logging.Level;    
  
  import java.util.logging.Logger;    
  
     
  
  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();    
  
              invoke(socket);    
  
          }    
  
      }    
  
     
  
      private static void invoke(final Socket socket) throws IOException {    
  
          new Thread(new Runnable() {    
  
              public void run() {    
  
                  ObjectInputStream is = null;    
  
                  ObjectOutputStream os = null;    
  
                  try {    
  
                      is = new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));    
  
                      os = new ObjectOutputStream(socket.getOutputStream());    
  
     
  
                      Object obj = is.readObject();    
  
                      User user = (User)obj;    
  
                      System.out.println("user: " + user.getName() + "/" + user.getPassword());    
  
     
  
                      user.setName(user.getName() + "_new");    
  
                      user.setPassword(user.getPassword() + "_new");    
  
     
  
                      os.writeObject(user);    
  
                      os.flush();    
  
                  } catch (IOException ex) {    
  
                      logger.log(Level.SEVERE, null, ex);    
  
                  } catch(ClassNotFoundException ex) {    
  
                      logger.log(Level.SEVERE, null, ex);    
  
                  } finally {    
  
                      try {    
  
                          is.close();    
  
                      } catch(Exception ex) {}    
  
                      try {    
  
                          os.close();    
  
                      } catch(Exception ex) {}    
  
                      try {    
  
                          socket.close();    
  
                      } catch(Exception ex) {}    
  
                  }    
  
              }    
  
          }).start();    
  
      }    
  
  }

Client也和Server端類似，同樣使用ObjectOutputStream和ObjectInputStream來處理，如下：

 
 
 
  
  
  package com.googlecode.garbagecan.test.socket.sample3;    
  
     
  
  import java.io.BufferedInputStream;    
  
  import java.io.IOException;    
  
  import java.io.ObjectInputStream;    
  
  import java.io.ObjectOutputStream;    
  
  import java.net.Socket;    
  
  import java.util.logging.Level;    
  
  import java.util.logging.Logger;    
  
     
  
  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 < 100; i++) {    
  
              Socket socket = null;    
  
              ObjectOutputStream os = null;    
  
              ObjectInputStream is = null;    
  
                  
  
              try {    
  
                  socket = new Socket("localhost", 10000);    
  
          
  
                  os = new ObjectOutputStream(socket.getOutputStream());    
  
                  User user = new User("user_" + i, "password_" + i);    
  
                  os.writeObject(user);    
  
                  os.flush();    
  
                      
  
                  is = new ObjectInputStream(new BufferedInputStream(socket.getInputStream()));    
  
                  Object obj = is.readObject();    
  
                  if (obj != null) {    
  
                      user = (User)obj;    
  
                      System.out.println("user: " + user.getName() + "/" + user.getPassword());    
  
                  }    
  
              } catch(IOException ex) {    
  
                  logger.log(Level.SEVERE, null, ex);    
  
              } finally {    
  
                  try {    
  
                      is.close();    
  
                  } catch(Exception ex) {}    
  
                  try {    
  
                      os.close();    
  
                  } catch(Exception ex) {}    
  
                  try {    
  
                      socket.close();    
  
                  } catch(Exception ex) {}    
  
              }    
  
          }    
  
      }    
  
  }

***測試上面的代碼，首先運行Server類，然后運行Client類，就可以分別在Server端和Client端控制臺看到接收到的User對象實例了。

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

名稱欄目：JavaSocket實戰(zhàn)之三：傳輸對象
瀏覽路徑：http://fisionsoft.com.cn/article/dpjjcdp.html

新聞中心

其他資訊