client.java

可以通过socket传输对象 主要是将传输的队列进行序列化 就可以轻松实现对象的传输

package ObjectSend;


import java.io.*;
import java.net.*;
public class Client {   
	
	private Socket socketConnection=null;
	private ObjectOutputStream clientOutputStream=null;
	private ObjectInputStream clientInputStream=null;
	Member member[] = new Member[1024]; 
	String string=new String();
	
	
	public Client(){	
		
		try {         
						socketConnection = new Socket("localhost", 11111);         
						clientOutputStream = new ObjectOutputStream(socketConnection.getOutputStream());
						clientInputStream = new ObjectInputStream(socketConnection.getInputStream());
						
						//clientOutputStream.writeObject(member);       
						//clientOutputStream.writeObject(string); 
						
						//member= (Member[])clientInputStream.readObject();         
						//str=(String)clientInputStream.readObject();
						
						
						/*
						for(int i=0;i<10;i++){
							
							System.out.println("Name= " + member[i].getName()); 
							System.out.println("ID= "   + member[i] .getID());
						}
						System.out.println(str);
						*/
						
						//clientOutputStream.close();         
						//clientInputStream.close();      
						
		} catch (Exception e) {
							System.out.println(e); 
		}   
	}
	
	public void sendString(String string) throws IOException, ClassNotFoundException{
		
		clientOutputStream.writeObject(string); 
				
	}
	
	public void sendObject(Member[] mem) throws IOException, ClassNotFoundException{
		
		clientOutputStream.writeObject(mem);
	
	
	}
	
	public String receiveString() throws IOException, ClassNotFoundException{
				
		string = (String)clientInputStream.readObject();
		return string;
	}
	
	public Member[] receiveObject() throws IOException, ClassNotFoundException{
				
		member = (Member[])clientInputStream.readObject();
		return member;
	}
	
	public void closeStream(){
		try {
			clientOutputStream.close();
			clientInputStream.close();  
		} catch (IOException e) {
			e.printStackTrace();
		}  
				
	}
	
	
	public static void main(String args[]) throws IOException, ClassNotFoundException, InterruptedException{
		Client client = new Client();
		client.sendString("hello");
		System.out.println(client.receiveString());
		client.sendString("我是客户端");
		
		Member mem[]=new Member[1024];
		mem=client.receiveObject();
		
        
        for(int i=0;i<10;i++){
				
				System.out.println("Name= " + mem[i].getName()); 
				System.out.println("ID= "   + mem[i] .getID());
			}
          
           
		
	}


}