基于Java的Socket服务器，简单实现

package com.wz.library; import java.io.*; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; /** */ public class SocketServerHelper { private static final String CHARSET = "UTF-8"; private static final int PORT = 12345; private ServerSocket mServerSocket; private ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5); public SocketServerHelper() { init(); } private void init() { // 创建一个服务器端socket，指定绑定的端口号，并监听此端口 try { mServerSocket = new ServerSocket(PORT); System.out.println("**********服务器即将启动，等待客户端的连接*************"); while (true) { Socket socket = mServerSocket.accept(); // 调用accept()方法开始监听，等待客户端的连接 scheduledThreadPool.execute(new SocketThread(socket)); } } catch (IOException e) { e.printStackTrace(); } } public void close() { if (mServerSocket != null) { try { mServerSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } private class SocketThread extends Thread { private Socket mSocket; private long lastHeartTime = System.currentTimeMillis(); SocketThread(Socket socket) { mSocket = socket; } @Override public void run() { super.run(); try { InputStream is = mSocket.getInputStream(); OutputStream os = mSocket.getOutputStream(); System.out.println("客户端--" + mSocket.getInetAddress().getHostName() + "--进入"); while (!mSocket.isClosed()) { if (System.currentTimeMillis() - lastHeartTime > 30 * 1000) { is.close(); os.close(); mSocket.close(); break; } byte[] bytes; int l = 0; while ((l = is.available()) > 0) { lastHeartTime = System.currentTimeMillis(); bytes = new byte[l]; is.read(bytes); String data = new String(bytes, CHARSET); System.out.println("客户端IP：" + mSocket.getInetAddress().getHostName()); System.out.println("客户端：" + data); os.write(data.getBytes(CHARSET)); os.flush(); if (data.equals("end")) { is.close(); os.close(); mSocket.close(); break; } } } System.out.println("客户端--" + mSocket.getInetAddress().getHostName() + "--断开"); } catch (EOFException e) { e.printStackTrace(); } catch (UnsupportedEncodingException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } } }