实现采用客户/服务器通信模式，基于TCP网络通信协议的多客户端简单应用

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

/*

 * 案例介绍：

 * 实现采用客户/服务器通信模式，

 * 基于TCP网络通信协议的多客户端简单应用

 * 案例设计：

 * 1：服务器端通过ServerSocket的accept方法等待客户端链接的到来

 * 2：客户端向服务端口发出TCP链接请求

 * 3：服务器端accept方法接收请求，启动新线程处理与该客户端之间通信的通信，服务器端

 * 主线程可继续等待客户端连续的请求。

 */

public class ChatServer {

public static void main(String[] args)throws IOException {
ServerSocket serverSocket=new ServerSocket(8888);
//先产生一个serverSocket，绑定一个端口
int number=1;//保存客户端的个数
while (true) {
Socket socket=serverSocket.accept();
System.out.println("客户端"+number+"连接成功！");
//服务端开启一个独立的线程来对客户端进行读写操作
new Thread(new ServerStream(socket, number)).start();
number++;

}

}
}

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

/*

 * 服务器端口为客户端产生一个线程

 */

public class ServerStream implements Runnable{

private Socket socket=null;

private int number;

//构造方法
public ServerStream(Socket socket, int number) {
super();
this.socket = socket;
this.number = number;

}
@Override
public void run() {
try {
BufferedReader br=new BufferedReader
(new InputStreamReader(socket.getInputStream()));
PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
while (true) {
String line=br.readLine();
System.out.println("客户端:"+number+"："+line);
pw.println(line.toUpperCase());
//把接收的字符串转换成大写的
if (line.equals("bye")) {
System.out.println("客户端"+number+"已经断开链接");
break;
}
}
br.close();
pw.close();
} catch (IOException e) {
e.printStackTrace();
}
}

}

/*

 * 客户端与服务端的链接

 */

import java.io.IOException;

import java.net.Socket;

public class ChatClient {

public static void main(String[] args)throws IOException{
Socket socket=new Socket("127.0.0.1", 8888);//链接服务器，并发送端口号
new Thread(new ClientInputStream(socket)).start();
new Thread(new ClientOutputStream(socket)).start();

}

}

/*

 * 客户端专门向服务端读的一个线程

 */

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.net.Socket;

import java.net.SocketException;

public class ClientInputStream implements Runnable{

private Socket socket=null;//要产生一个输入流就要先产生一个socket

//构造方法
public ClientInputStream(Socket socket) {
super();
this.socket = socket;

}
@Override
public void run() {
try {
BufferedReader br=new BufferedReader
(new InputStreamReader(socket.getInputStream() ));

while (true) {
try {
String line=br.readLine();
System.out.println(line);
} catch (SocketException e) {

break;
}

}
br.close();
} catch (IOException e) {
e.printStackTrace();
}

}

}

/*

 * 客户端专门向服务端写的一个线程

 */

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.PrintWriter;

import java.net.Socket;

public class ClientOutputStream implements Runnable{

private Socket socket=null;

//构造方法
public ClientOutputStream(Socket socket) {
super();
this.socket = socket;

}

@Override
public void run() {
try {
BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
//自动刷新缓冲区
while (true) {
String  line=br.readLine();
pw.println(line);
if (line.equals("bye")) {
break;
}
}
br.close();
pw.close();
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}

}