Java Socket 多线程编程，处理百万级的数据并发。

感谢网上的大神分享的代码，然后我根据我们项目的需求，组装成余下代码，基本上大概的框架就是这个模式，需要修改的就是业务数据的传递 ，其他的都是不用修改的。

本着学习他人代码，学会他人分享精神，因此将我花了两天研究的代码分享出来（晚上的时间）。希望有大神多多指教我这个编程菜鸟的技术，本菜鸟感激不敬。

ServerSocket ：

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.Buffer;

public class TalkServer {

	public static void main(String[] args) throws IOException{
		ServerSocket server = new ServerSocket(5203);
		while(true){
			Socket socket = server.accept();
			exSocketServer(socket);
		}
	}
	public static void exSocketServer(final Socket socket){

		new Thread(new Runnable() {

			@Override
			public void run() {
				// TODO Auto-generated method stub
				BufferedReader in = null;
				PrintWriter out = null;
				try {
					in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
					out=new PrintWriter(socket.getOutputStream());
					while(true){
						String msg =in.readLine();
						if(msg == null){
							break;
						}
						System.out.println("Client :"+msg);
						//返回消息给客户端。
						out.println("OK ！");
						out.flush();

					}
				}catch(Exception e){
					//e.printStackTrace();
					System.out.println("Error:"+e);
				}finally {
					try {
						in.close();
						out.close();
						socket.close();
					} catch (IOException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}

				}

			}
		}).start();
	}
}

客户A端的代码：

import java.io.*;

import java.net.*;

public class TalkClient {

			public static void main(String args[]) {
				String rootPath=TalkClient.class.getResource("/").getFile().toString();
		    	String fileName =rootPath+"Initialize.txt";

					String file = "my name is YI! nice to meet you";//ReadFromFile.readFileByLinesln(fileName);
					exSocket(file);
		}

			public static void exSocket(String file){
				try{
					InetAddress addr = InetAddress.getByName("localhost");
					Socket socket=new Socket(addr,5203);
					BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
					PrintWriter out=new PrintWriter(socket.getOutputStream());
					for(int i =0 ;i<1000000;i++){
					String readline= file+i+"AAAA" ;;  //sin.readLine(); //从系统标准输入读入一字符串
					//将从系统标准输入读入的字符串输出到Server
					out.println(readline);
					//刷新输出流，使Server马上收到该字符串
					out.flush();
					System.out.println("Client:"+readline);

					System.out.println("Servlet :"+in.readLine());
					}
					socket.close(); //关闭Socket

					}catch(Exception e) {

					System.out.println("Error"+e); //出错，则打印出错信息

					}

			}

}

客户B端的代码：

import java.io.*;

import java.net.*;

public class TalkClient {

			public static void main(String args[]) {
				String rootPath=TalkClient.class.getResource("/").getFile().toString();
		    	String fileName =rootPath+"Initialize.txt";

					String file = "my name is YI! nice to meet you";//ReadFromFile.readFileByLinesln(fileName);
					exSocket(file);
		}

			public static void exSocket(String file){
				try{
					InetAddress addr = InetAddress.getByName("localhost");
					Socket socket=new Socket(addr,5203);
					BufferedReader in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
					PrintWriter out=new PrintWriter(socket.getOutputStream());
					for(int i =0 ;i<1000000;i++){
					String readline= file+i+"BBBB" ;;  //sin.readLine(); //从系统标准输入读入一字符串
					//将从系统标准输入读入的字符串输出到Server
					out.println(readline);
					//刷新输出流，使Server马上收到该字符串
					out.flush();
					System.out.println("Client:"+readline);

					System.out.println("Servlet :"+in.readLine());
					}
					socket.close(); //关闭Socket

					}catch(Exception e) {

					System.out.println("Error"+e); //出错，则打印出错信息

					}

			}

}