socket接收消息并进行反馈

1、服务器端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

/**
 * 编写一个Java网络应用程序，该应用分服务器端程序和客户端程序两部分。
 * 服务器程序启动后，监听端口5678的请求；客户端程序启动后，向服务器端口5678发送请求。
 * 服务器不断接收客户机所写入的信息，并且服务器也会做出"Receive"为回应，告知客户机已接收到消息。
 * 要求：服务器程序采用多线程开发，
 * 允许多个客户端程序同时连接。客户机发送"End"字符串时，客户端程序退出。
 * @author Administrator
 */
public class Server {
	
	public static ArrayList<Socket> socketList = new ArrayList<Socket>();
	public static void main(String[] args){
		try {
			ServerSocket ss = new ServerSocket(5678);
			while(true){
				System.out.println("等待连接...");
				Socket s = ss.accept();
				// 每收到一个socket连接 ，则启动一条SeverThread线程
				System.out.println("连接成功，等待客户端输入信息！");
				socketList.add(s);
				new Thread(new SeverThread(s)).start();
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		};
	}
}

class SeverThread implements Runnable{

	Socket s = null;
	BufferedReader br = null;
	PrintStream ps = null;
	
	public SeverThread(Socket s) {
		this.s = s;
		try {
			// 初始化该socket对应的输入流    得到客户端的信息
			br = new BufferedReader(new InputStreamReader(s.getInputStream()));
			// 获取该socket对应的输出流
		    ps = new PrintStream(s.getOutputStream());
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		String content = null;
		try {
			
			while((content = br.readLine()) != null){
				
				System.out.println("content : " + content);	
				// 向客户端发出反馈消息
				ps.println("Receive");
				 //判断是否结束
			    if(content.equals("End"))
			    {
			    	System.out.println("对话结束！");
			    	s.shutdownOutput();
			    	break;
			    }
			}
			
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			
		}
		finally{
			try {
				br.close();
				ps.close();
				Server.socketList.remove(s);
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
	
}

2、客户端

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Socket s = null;
		try {
			s = new Socket("127.0.0.1",5678);
			new Thread(new ClientThread(s)).start();
			// 获取该socket对应的输出流
			PrintStream ps = new PrintStream(s.getOutputStream());
			String line = null;
			// 不断读取键盘输入
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
			while((line = br.readLine()) != null || !(line = br.readLine()).equals("End")){
				ps.println(line);
			}
			s.shutdownOutput();
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

class ClientThread implements Runnable{

	Socket s = null;
	// 初始化该socket对应的输入流
	BufferedReader br = null;
	public ClientThread(Socket s) throws IOException {
		this.s = s;
		try {
			br = new BufferedReader(new InputStreamReader(s.getInputStream()));
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		String content = null;
		try {
			while((content = br.readLine())!= null){
				System.out.println("服务器端返回的数据：" + content);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				br.close();
				s.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
	
}