Java Socket实战之二:多线程通信
2023-03-14 22:55:39 时间
上一篇文章说到怎样写一个最简单的Java Socket通信,但是在上一篇文章中的例子有一个问题就是Server只能接受一个Client请求,当第一个Client连接后就占据了这个位置,后续Client不能再继续连接,所以需要做些改动,当Server没接受到一个Client连接请求之后,都把处理流程放到一个独立的线程里去运行,然后等待下一个Client连接请求,这样就不会阻塞Server端接收请求了。每个独立运行的程序在使用完Socket对象之后要将其关闭。
具体代码如下:
- package com.googlecode.garbagecan.test.socket.sample2;
- import java.io.BufferedReader;
- import java.io.IOException;
- import java.io.InputStreamReader;
- import java.io.PrintWriter;
- import java.net.ServerSocket;
- import java.net.Socket;
- public class MyServer {
- public static void main(String[] args) throws IOException {
- ServerSocket server = new ServerSocket(10000);
- while (true) {
- Socket socket = server.accept();
- invoke(socket);
- }
- }
- private static void invoke(final Socket client) throws IOException {
- new Thread(new Runnable() {
- public void run() {
- BufferedReader in = null;
- PrintWriter out = null;
- try {
- in = new BufferedReader(new InputStreamReader(client.getInputStream()));
- out = new PrintWriter(client.getOutputStream());
- while (true) {
- String msg = in.readLine();
- System.out.println(msg);
- out.println("Server received " + msg);
- out.flush();
- if (msg.equals("bye")) {
- break;
- }
- }
- } catch(IOException ex) {
- ex.printStackTrace();
- } finally {
- try {
- in.close();
- } catch (Exception e) {}
- try {
- out.close();
- } catch (Exception e) {}
- try {
- client.close();
- } catch (Exception e) {}
- }
- }
- }).start();
- }
- }
下面是Client程序代码:
- package com.googlecode.garbagecan.test.socket.sample2;
- import java.io.BufferedReader;
- import java.io.InputStreamReader;
- import java.io.PrintWriter;
- import java.net.Socket;
- public class MyClient {
- public static void main(String[] args) throws Exception {
- Socket socket = new Socket("localhost", 10000);
- BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- PrintWriter out = new PrintWriter(socket.getOutputStream());
- BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
- while (true) {
- String msg = reader.readLine();
- out.println(msg);
- out.flush();
- if (msg.equals("bye")) {
- break;
- }
- System.out.println(in.readLine());
- }
- socket.close();
- }
- }
测试,首先运行MyServer类,然后运行两个MyClient类,然后分别在每个MyClient的提示符下输入字符串,就可以看到Server可以分别接收处理每个Client的请求了。
原文链接:http://blog.csdn.net/kongxx/article/details/7259465
【编辑推荐】
相关文章
- 真正的大数据问题以及为什么只有机器学习才能解决它
- 民生银行数据中台体系的构建与实践
- 云数据管理会成为DataOps的未来吗?
- 企业可以不要大数据,但必须要有“数据中台”
- PHP 源码探秘 - 为什么 trim 会导致乱码
- 态牛-Tech Neo 9月刊:基于算法的IT运维
- 数据科学和分析的热门市场
- 你公司所拥有的数据,真正被使用的有多少?
- 学Hadoop你必须要知道的
- 如何实现PHP长网址与短网址
- PHP的垃圾回收机制——引用计数
- 数据分析有哪些好书值得推荐?
- 论HTTP性能,Go与.NET Core一争雌雄
- 大数据与离婚:企业如何利用生活变化
- 2017年10月编程语言排行榜:Swift回到第16位
- Go语言大神亲述:历七劫方可成为程序员!
- 杨镇:从大数据与 AI 技术发展来看,跨链技术必要且必然
- PHP7中我们应该学习会用的新特性
- 数据科学家需要了解的5种采样方法
- 是什么让数据科学家从优秀变得伟大?