public class MallShopSoketServer implements Runnable {
private static Logger logger = Logger.getLogger(MallShopSoketServer.class);
private int port = 8821;
private ServerSocket serverSocket;
private ExecutorService executorService;// 线程池
private final int POOL_SIZE = 10;// 单个CPU线程池大小
public MallShopSoketServer() {
try {
serverSocket = new ServerSocket(port);
} catch (Exception e) {
logger.error(e);
}
executorService = Executors.newFixedThreadPool(POOL_SIZE);
logger.info("商城Sokect Server 启动,端口:" + port);
}
public void run() {
try {
while (true) {
Socket socket = null;
// 接收客户连接,只要客户进行了连接,就会触发accept();从而建立连接
socket = serverSocket.accept();
executorService.execute(new MallShopHandler(socket));
}
} catch (Exception e) {
logger.error(e);
}
}
}
/**
* 商城信息处理器
*
* @author panxiuyan
*
*/
public class MallShopHandler implements Runnable {
private Logger logger = Logger.getLogger(MallShopHandler.class);
private Socket socket;
public MallShopHandler(Socket socket) {
this.socket = socket;
}
/**
* 获取Socket 输入流
*
* @param socket
* @return
* @throws IOException
*/
private PrintWriter getWriter(Socket socket) throws IOException {
OutputStream socketOut = socket.getOutputStream();
return new PrintWriter(socketOut, true);
}
/**
* 获取socket 输出流
*
* @param socket
* @return
* @throws IOException
*/
private BufferedReader getReader(Socket socket) throws IOException {
InputStream socketIn = socket.getInputStream();
return new BufferedReader(new InputStreamReader(socketIn));
}
public void run() {
try {
logger.info("New connection accepted " + socket.getInetAddress()
+ ":" + socket.getPort());
BufferedReader br = getReader(socket);
PrintWriter pw = getWriter(socket);
String msg = br.readLine();
pw.println(doMsg(msg));
} catch (IOException e) {
logger.error(e);
} finally {
try {
if (socket != null)
socket.close();
} catch (IOException e) {
logger.error(e);
}
}
}
/**
* 处理信息
*
* @param msg
* @return
*/
public String doMsg(String msg) {
.................
}
}
分享到:
相关推荐
客户端的请求首先会进入请求队列,处理器线程池会向请求队列获取请求并且分配分配处理器,每个处理器...处理器可以指定interceptor,处理逻辑都实现在ResponseHandler中。空闲时,处理器线程会休眠直到有新的请求到来
使用java多线程实现java Socket的一个服务端,多个客户端可共同通讯的功能
java socket 多线程 简易的实现方法 细节问题没有处理 适合新手
使用java socket开发的多线程文件上传下载的实例项目,多线程并发测试中可以支持200个,可能由于我电脑的配置问题,一般在并发大于200时client端可能会出现"阻塞"问题,还请大家指教
java多线程并发控制通信,用hibernate存储信息,数据库mysql.
NULL 博文链接:https://lisanlai.iteye.com/blog/721084
在主线程中通过控制台读取键盘...服务器在收到一个socket连接之后,把该socket保存到队列中,并对队列中的每个socket开启各自的读写线程。测试可以在不同控制台运行server和client,服务器接收消息时,会显示消息来源
java socket 多线程网络传输多个文件
该软件是一个基于java语言的socket编程,可以实现单个服务器对应多个客户端的聊天。采用swt,功能还是比较完善的。
基于多线程实现的JavaSocket客户端-服务端点对点异步通信程序代码
Java Socket多线程实例及文档,给大家分享这个期待你的加入。Java Socket多线程实例及文档
java语言,基于socket的多线程一对一聊天,暂不支持并发
Java Socket实例(服务器多线程) 自己写的代码
内含2248张图片所以有点大 利用java socket多线程来轮播图片的方式实现的视频效果 先运行SocketListener.java 在运行SocketVideo.java 希望给点好评论
服务端知识进行连接 之后调用服务端的线程 服务端并没有大的改动,在原有的基础上加上线程池, 客户端界面只有简单的传一个...调用客户端的方法,方法中有线程,线程中进行socket的链接,这样才能实现多个文件的传输。
网络通信之Java Socket多线程通信.pdf
多线程多人聊天室,在多线程的基础上建立其模块功能包括client,server,user
Java多线程-Socket编程
Java5 Socket多线程实践.