俊星的BLOG

          我的JAVA工具之網絡傳輸對象

          import java.io.ObjectInputStream;
          import java.io.ObjectOutputStream;
          import java.io.Serializable;
          import java.net.ServerSocket;
          import java.net.Socket;

          public class Tet {
              
          public static void main(String[] args) {
                  
          new Server().start();
                  
          new Client().start();
              }

          }


          class TestVO implements Serializable {
              
          private String name;
              
          private int id;

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


              
          public String toString() {
                  
          return "id:" + id + " name:" + name;
              }

          }


          class Client extends Thread {
              
          public void run() {
                  
          try {
                      Socket client 
          = new Socket("localhost"8888);
                      ObjectInputStream ois 
          = new ObjectInputStream(client.getInputStream());
                      TestVO vo 
          = (TestVO) ois.readObject();
                      System.out.println(
          "client read:" + vo);
                      ois.close();
                      client.close();
                  }
           catch (Exception e) {
                      
          // TODO: handle exception
                      e.printStackTrace();
                  }

              }

          }


          class Server extends Thread {
              
          public void run() {
                  
          try {
                      ServerSocket ss 
          = new ServerSocket(8888);
                      Socket server 
          = ss.accept();
                      ObjectOutputStream oos 
          = new ObjectOutputStream(server.getOutputStream());
                      TestVO vo 
          = new TestVO(1"good job");
                      oos.writeObject(vo);
                      System.out.println(
          "server write:" + vo);
                      oos.close();
                      server.close();
                      ss.close();
                  }
           catch (Exception e) {
                      
          // TODO: handle exception
                  }

              }

          }

          輸出:
          server write:id:1 name:good job
          client read:id:
          1 name:good job

          posted on 2009-05-19 21:40 俊星 閱讀(576) 評論(0)  編輯  收藏


          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 博罗县| 华安县| 开阳县| 金溪县| 庆元县| 梁河县| 阿荣旗| 开化县| 桐乡市| 江陵县| 庆元县| 同江市| 宣城市| 余江县| 河津市| 伊宁市| 海口市| 襄城县| 克什克腾旗| 新绛县| 荃湾区| 金溪县| 怀柔区| 垫江县| 大田县| 靖州| 潜山县| 安宁市| 涿州市| 万安县| 陕西省| 沂南县| 平南县| 宾川县| 永宁县| 千阳县| 那坡县| 南充市| 济宁市| 铜鼓县| 东乌珠穆沁旗|