## 多线程服务器
应用多线程实现服务器与多客户端之间的通信
### 基本步骤
1. 服务器端创建ServerSocket，循环调用accept()等待客户端连接
2. 客户端创建一个socket并请求和服务器端连接
3. 服务器端接受客户端请求，创建socket与该客户建立专线连接
4. 建立连接的两个socket在一个单独的线程上对话
5. 服务器端矩形等待新的连接
### 实现实例代码
通过多线程处理多个连接
~~~java
/*
* 服务器线程处理类
*/
public class ServerThread extends Thread {
// 和本线程相关的Socket
Socket socket = null;
public ServerThread(Socket socket) {
this.socket = socket;
}
// 线程执行的操作，响应客户端的请求
public void run() {
InputStream is = null;
InputStreamReader isr = null;
BufferedReader br = null;
OutputStream os = null;
PrintWriter pw = null;
try {
is = socket.getInputStream();
isr = new InputStreamReader(is);
br = new BufferedReader(isr);
String info = null;
while ((info = br.readLine()) != null) {
// 循环读取客户端的信息
System.out.println("我是服务器，客户端说：" + info);
}
socket.shutdownInput();// 关闭输入流
// 获取输出流，响应客户端的请求
os = socket.getOutputStream();
pw = new PrintWriter(os);
pw.write("欢迎你");
pw.flush();// 调用flush()方法将缓冲输出
} catch (IOException e) {
e.printStackTrace();
} finally {
// 关闭资源
try {
if (pw != null) {
pw.close();
}
if (os != null) {
os.close();
}
if (br != null) {
br.close();
}
if (isr != null) {
isr.close();
}
if (is != null) {
is.close();
}
if (socket != null) {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
~~~
---
服务器循环监听
~~~java
public class Server {
/**
* 基于TCP协议的Socket通信，实现用户登陆 服务器端
* @param args
*/
public static void main(String[] args) {
try {
// 1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
ServerSocket serverSocket = new ServerSocket(8886);
Socket socket = null;
// 记录客户端的数量
int count = 0;
System.out.println("***服务器启动***");
// 循环监听客户端的连接
while (true) {
socket = serverSocket.accept();
// 创建一个新的线程
ServerThread serverThread = new ServerThread(socket);
// 启动线程
serverThread.start();
count++;
System.out.println("客户端数量：" + count);
InetAddress address = socket.getInetAddress();
System.out.println("当前客户端的IP：" + address.getHostAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
~~~
---
客户端代码
~~~java
public class Client {
/**客户端
* @param args
*/
public static void main(String[] args) {
try {
//1、创建客户端Socket，指定服务器地址和端口
Socket socket = new Socket("localhost",8886);
//2、获取输出流，向服务端发送信息
OutputStream os = socket.getOutputStream();//字节输出流
PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流
pw.write("用户名：admin；密码：123");
pw.flush();
socket.shutdownOutput();//关闭输出流
//3.获取输入流，并读取服务器端的响应信息
InputStream is= socket.getInputStream();
BufferedReader br = new BufferedReader(new InputStreamReader(is));
String info = null;
while ((info = br.readLine()) != null) {
// 循环读取客户端的信息
System.out.println("我是客户端，服务端说：" + info);
}
//4.关闭资源
br.close();
is.close();
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
~~~
