Java Socket编程(三) 并发服务器
看一下代码
package com.yjp.server;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
public class ToUpperTCPThreadServer {
//服务器IP
public static final String SERVER_IP = "127.0.0.1";
//服务器端口号
public static final int SERVER_PORT = 10005;
//请求终结字符串
public static final char REQUEST_END_CHAR = '#';
/***
* 启动服务器
* @param 服务器监听的端口号，服务器ip无需指定，系统自动分配
*/
public void startServer(String serverIP, int serverPort) {
//创建服务器地址对象
InetAddress serverAddr;
try {
serverAddr = InetAddress.getByName(serverIP);
} catch (UnknownHostException e1) {
e1.printStackTrace();
return;
}
//Java提供了ServerSocket作为服务器
//这里使用了Java的自动关闭的语法，很好用
try (ServerSocket serverSocket = new ServerSocket(SERVER_PORT, 5, serverAddr)) {
while (true) {
StringBuilder recvStrBuilder = new StringBuilder();
try {
//有客户端向服务器发起tcp连接时，accept会返回一个Socket
//该Socket的対端就是客户端的Socket
//具体过程可以查看TCP三次握手过程
Socket connection = serverSocket.accept();
//利用线程池，启动线程
Executor executor = Executors.newFixedThreadPool(100);
executor.execute(new Runnable() {
@Override
public void run() {
//使用局部引用，防止connection被回收
Socket conn = connection;
try {
InputStream in = conn.getInputStream();
//读取客户端的请求字符串，请求字符串以#终结
for (int c = in.read(); c != REQUEST_END_CHAR; c = in.read()) {
recvStrBuilder.append((char)c);
}
recvStrBuilder.append('#');
String recvStr = recvStrBuilder.toString();
//向客户端写出处理后的字符串
OutputStream out = conn.getOutputStream();
out.write(recvStr.toUpperCase().getBytes());
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (conn != null) {
conn.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
});
} catch (IOException e) {
e.printStackTrace();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
ToUpperTCPThreadServer server = new ToUpperTCPThreadServer();
server.startServer(SERVER_IP, SERVER_PORT);
}
}与上一篇文章比较，差别仅在于当accept返回socket后，启动线程处理，这里使用了Excutor，基于线程池进行处理。另外注意在Runnable的run方法中，使用一个局部对象引用connection，防止被JVM回收。将上一篇给出的客户端程序main函数中的常量改为使用ToUpperTCPThreadServer的常量即可。
转载自：http://blog.csdn.net/yjp19871013/article/details/53607388
Java Socket编程(一) Socket编程原理及基本概念
http://wisdomdd.cn/Wisdom/resource/articleDetail.htm?resourceId=501
Java Socket编程(二) 几种常见的服务器模型
http://wisdomdd.cn/Wisdom/resource/articleDetail.htm?resourceId=502
Java Socket编程(四) 异步服务器
http://wisdomdd.cn/Wisdom/resource/articleDetail.htm?resourceId=504