Socket 实现跨域传送对象

import java.io.*;import java.net.*;
public class Client { 
    public static void main(String[] arg) { 
        try {      
            Employee joe = new Employee();
            Socket socketConnection = new Socket("192.168.1.17", 8781); 
            ObjectOutputStream clientOutputStream = new ObjectOutputStream(socketConnection.getOutputStream()); 
            ObjectInputStream clientInputStream = new ObjectInputStream(socketConnection.getInputStream());  
            joe.setSendState("发送");
            joe.setTitle("qichao");
            clientOutputStream.writeObject(joe);
            clientOutputStream.flush();
            joe = (Employee)clientInputStream.readObject();
            if(joe.getSendState().equals("下一条")){
                joe.setSendState("发送");
                joe.setTitle("loiy");
                clientOutputStream.writeObject(joe);
                clientOutputStream.flush();
            }
            while(true){
               
            }
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}

 

import java.io.*; import java.net.*; 

import agrlinkUpateAdress.agrilinkFileEle;
public class Server { 
	public static void main(String[] arg) { 
		Employee employee = null; 
		try { 
			ServerSocket socketConnection = new ServerSocket(8781);
			Socket pipe = socketConnection.accept();
			ObjectInputStream serverInputStream = new ObjectInputStream(pipe.getInputStream());
			ObjectOutputStream serverOutputStream = new ObjectOutputStream(pipe.getOutputStream());
			employee = (Employee)serverInputStream.readObject();
			String SendState = employee.getSendState();
			while(SendState!=null){
				System.out.println("SendState="+SendState+" "+employee.getTitle());
				if(SendState.equals("bye")){
					SendState = null;
					//closeSocket();
				}else{		
					//数据入库,入完,返回信息给客户端,准备接受下一条信息
					//Send(acceptComplate);
					employee.setSendState("下一条");
					serverOutputStream.writeObject(employee);
					serverOutputStream.flush();
					employee = (Employee)serverInputStream.readObject();
					SendState = employee.getSendState();
				}
			}
		}catch(Exception e) {
			System.out.println(e);
		}
	} 
}