package com.best.alivn.socketservice;
import java.io.*;
import java.net.Socket;
import java.util.Scanner;/**让服务器处理与客户端通讯放在线程中* Created by Alivn on 2017/3/18.*/
public class SessionThread  implements Runnable{private final Socket client;private static Integer Tag=0;public SessionThread(Socket client) {this.client = client;}@Overridepublic void run() {//输出流PrintWriter writer=null;//获取客户端输入流，得到客户端发来的消息try {//读取客户端的数据//读取到的一行数据String line=null;//客户端发来的数据//开启一个读线程Thread write_thread= new Thread(new Runnable() {@Overridepublic void run() {//输入流InputStream inputStream=null;BufferedReader reader=null;try {while (true) {inputStream= client.getInputStream();//为了提高效率，转换成字符流reader=new BufferedReader(new InputStreamReader(inputStream));String line=null;while ((line=reader.readLine())!=null){System.out.println(line);}}} catch (IOException e) {//流异常
                        e.printStackTrace();}finally {//关闭流try {inputStream.close();reader.close();} catch (IOException e) {e.printStackTrace();}}}});write_thread.start();//获取输出流，往客户端发送数据writer=new PrintWriter(client.getOutputStream());//客户端刚连接的时候，客户端反馈信息String send_msg ="您已成功连接到服务器......--[Server]";writer.println(send_msg);writer.flush();//可以多次发送//从键盘输入while ("1".equals("1")) {Scanner scanner=new Scanner(System.in);send_msg =scanner.nextLine()+"--[Server]";writer.println(send_msg);//注意（我们发送数据的时候，flush方法会提交我们的数据，但是还不会发送，当数据达到一定容量才会发送，// 或者读到换行符的时候发送）
                writer.flush();}} catch (IOException e) {//获取客户端输入流失败
            e.printStackTrace();}finally {//关闭流try {client.shutdownInput();client.shutdownOutput();writer.close();} catch (IOException e) {//关闭输入输出流失败
                e.printStackTrace();}}}
}

package com.best.alivn.socketservice;
import scala.actors.threadpool.ExecutorService;
import scala.actors.threadpool.Executors;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;/**服务器* Created by Alivn on 2017/3/18.*/
public class Server {//甚至端口号private  final static Integer PORT=8888;//设置开启的线程数private  final  static  Integer THREAD_SIZE=5;//创建线程池private  static  ExecutorService executorService=null;public static void main(String[]args){executorService  = Executors.newFixedThreadPool(THREAD_SIZE);//创建服务器套接字try {//创建三个线程放入到线程池中....ServerSocket serverSocket=new ServerSocket(PORT);//开启服务器，一直处于监听的状态System.out.println("[Server]:服务器已启动.........");while (true){//服务器根据端口号，监听客户端链接，Socket client = serverSocket.accept();System.out.println("[Server]：有客户端链接至服务器.......");//将交互放到线程中SessionThread session=new SessionThread(client);//放入到线程池中
                session.run();executorService.execute(session);}} catch (IOException e) {//实例化服务器失败
            e.printStackTrace();}}}

package com.best.alivn.socketservice;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;/**客户端* Created by Alivn on 2017/3/18.*/
public class Client {private final  static  String host="localhost";private final  static  Integer port=8888;public  static  void main(String[] args)  {Socket socket=null;//输入流BufferedReader reader=null;//创建客户端对象try {//连接服务器socket=new Socket(host,port);//客户端刚连接的时候，客户端反馈信息//输出流final PrintWriter writer=new PrintWriter(socket.getOutputStream());;String  send_msg ="你好，我是小白......--[Client]";writer.println(send_msg);writer.flush();//开启一个线程，处理循环Thread write_Stream=  new Thread(new Runnable() {@Overridepublic void run() {//循环输入数据Scanner scanner=new Scanner(System.in);while ("1".equals("1")){String send_msg=scanner.nextLine()+"--[Client]";writer.println(send_msg);writer.flush();}}});write_Stream.start();while ("1".equals("1")) {//获取输入流，得服务端的数据reader=new BufferedReader(new InputStreamReader(socket.getInputStream()));String line=null;while ((line=reader.readLine())!=null){System.out.println(line);}}writer.close();} catch (IOException e) {//链接失败   文件读取失败
            e.printStackTrace();}finally {//关闭流try {reader.close();socket.shutdownInput();socket.shutdownOutput();} catch (IOException e) {e.printStackTrace();}}}
}