socket objectoutputstream 传对象 例子

/* * To change this template, choose Tools | Templates * and open the template in the editor. */ package page; /** * * @author zhou_h */ import java.io.IOException; import java.io.ObjectOutputStream; import java.net.Socket; import java.util.HashMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class AtomsClient { public static void main(String args[]) throws InterruptedException { ExecutorService exec = Executors.newFixedThreadPool(2); for (int index = 0; index<=10; index++) { Runnable run = new Runnable() { HashMap<Object,Object> map=null; private Socket socket = null; private int port = 8833; AtomsData atomsdata; ObjectOutputStream oos = null; public void run() { while (true) { try { socket = new Socket("localhost", port); map=new HashMap<Object, Object>(); atomsdata = new AtomsData(); atomsdata.setVersion((new Double((long) (Math.random() * 1000))).toString()); map.put("value",atomsdata); map.put("operation","doit"); oos = new ObjectOutputStream(socket.getOutputStream()); oos.writeObject(map); } catch (IOException e) { e.printStackTrace(); } finally { try { oos.close(); } catch (Exception e) { e.printStackTrace(); } } } } }; exec.execute(run); } exec.shutdown(); } }