multithreadserversocketdemo.java

java程序设计教程的源码

//【例11-7】  基于多线程的服务器程序。
//程序清单11-7:  MultithreadServerSocketDemo.java
package socket;
import java.io.*;
import java.net.*;
public class MultithreadServerSocketDemo {// 主类
	final static int PORT = 55558;// 服务器端与客户端使用的通信端口
	public static void main(String[] args) {
		ServerSocket serversocket = null;// 服务器端套接字引用
		Socket socket = null;// 客户器端套接字引用
try {// 以PORT为服务端口，创建服务器端ServerSocket类的对象，以监听该端口上的连接
			serversocket = new ServerSocket(PORT);
			System.out.println("服务器正常启动！\n" + serversocket);
			while (true) {
	        // 以循环方式，用accept()获取并保存多个连接到服务器的客户端Socket类的对象
				socket = serversocket.accept();
				try {// 使用多线程类完成对客户端的请求响应，实现数据交换
					new MultithreadServerSocket(socket);
				} catch (IOException e) {
					e.printStackTrace();
					socket.close();
				}
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				serversocket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
			System.out.println("服务器端正常关闭连接！");
		}
	}
}
class MultithreadServerSocket extends Thread {// 定义多线程类
	private Socket msocket = null;// 客户端Socket类的对象引用socket
	private BufferedReader in;// 服务器端输入流
	private PrintWriter out;// 服务器端输出流
	public MultithreadServerSocket(Socket socket) throws IOException {
		msocket = socket;
		// 创建并包装服务器端获取的socket对象的输入流
in= new BufferedReader(new InputStreamReader(msocket.getInputStream()));
		// 创建并包装服务器端获取的socket对象的输出流
out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(msocket
				.getOutputStream())), true);
		start();// 启动线程
		System.out.println("\n与客户端线程" + this.getName() + "建立连接！\n" + socket);
	}
	public void run() {// 线程体
		try {
			int count = 0;
			while (true) {
				String strin = in.readLine();// 从客户器端读入数据
				if (strin.equals("结束"))
					break;
				System.out.println("Echoing: " + strin);
				out.println("From Server " + ++count);// 向客户器端输出数据
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			{// 关闭连接，释放网络资源
				try {
					out.close();//
					in.close();//
					msocket.close();
					System.out.println("正常关闭线程：" + this.getName());
				} catch (IOException e) {
					e.printStackTrace();
				}
			}
		}
	}
}