java socket实例
/**
* 启动项目后就创建Server Socket服务
*/
@PostConstruct
public void runServerSocket() {
try {
ExecutorService executorService = Executors.newFixedThreadPool(10);// 创建线程池
ServerSocket serverSocket = new ServerSocket(9090);// 在设备上配置的服务端监听端口为9090
executorService.execute(()->{
while (true) {
try {
Socket socket = serverSocket.accept();
InputStream in = socket.getInputStream();// 获取输入流，用来读取数据
byte[] data = new byte[128];
in.read(data);
String dataStr = new String(data,"utf-8");
System.out.println(dataStr);
in.close();
socket.close();
executorService.shutdown();
} catch (Exception e) {
executorService.shutdown();
} finally {
executorService.shutdown();
}
}
});
} catch (Exception e) {
e.printStackTrace();
}
}