simpleserversocketdemo.java

java程序设计教程的源码

//【例11-5】  基于Socket的简单服务器程序。
//程序清单11-5:  SimpleServerSocketDemo.java
package socket;
import java.io.*;
import java.net.*;
public class SimpleServerSocketDemo {
	public static void main(String[] args) throws IOException {
		new SimpleServerSocket();
	}
}
class SimpleServerSocket {
	final static int PORT = 55558;// 服务器端与客户端使用的通信端口
	ServerSocket serversocket;// 服务器ServerSocket类的对象引用
	Socket socket = null;// 客户端Socket类的对象引用socket
	BufferedReader in;// 服务器端输入流
	PrintWriter out;// 服务器端输出流
	public SimpleServerSocket() {
		int count = 0;
	try {// 以PORT为服务端口，创建服务器端ServerSocket类的serversocket对象，以监听该端口上的连接
			serversocket = new ServerSocket(PORT);
			System.out.println("服务器正常启动！\n" + serversocket);
			// 用阻塞方法accept()获取并保存连接到服务器的客户端Socket类的对象
			socket = serversocket.accept();
			System.out.println("与客户端建立连接！\n" + socket);
			// 创建并包装服务器端获取的socket对象的输入流
			in = new BufferedReader(new InputStreamReader(socket
					.getInputStream()));
			// 创建并包装服务器端获取的socket对象的输出流
			// PrintWriter流能自动刷新输出缓冲区（println()结束时）
		out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
			while (true) {
				String str = in.readLine();// 从客户器端读入数据
				if (str.equals("结束"))
					break;
				System.out.println("Echoing: " + str);
				out.println("From Server " + ++count);// 向客户器端输出数据
			}
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			{// 关闭连接，释放网络资源
				out.close();
				try {
					in.close();
					socket.close();
					serversocket.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
				System.out.println("服务器端正常关闭连接！");
			}
		}
	}
}