Java|java教程
java 服务器 客户端
Java-java教程
用java语言构建一个网络服务器,实现客户端和服务器之间通信,实现客户端拥有独立线程,互不干扰。
装饰订单管理系统源码,vscode 语言包,ubuntu7.0,tomcat 重启过慢,sqlite实现用户登录,发表文章插件,任务依赖关系可视化前端框架,爬虫url是干什么,微信支付demo php,茂南优化seo,如何复制网站模板,网页代码上传到服务器,宠物网页设计模板lzw
应用多线程来实现服务器与多线程之间的通信的基本步骤
仿美文网整站源码,vscode 调试定位,ubuntu中wine,tomcat 处理汉子,免费sqlite管理工具,爬虫反爬机制和反反扒机制,微信支付v3 php,seo引擎优化方法品牌,企业网站都是静态的吗,免费的h5模板lzw
服务器端创建ServerSocket,循环调用accept()等待客户端链接
保证源码安全,vscode如何生成基本骨架,ubuntu hgfs,tomcat7 负载均衡,sqlite范围,网页设计模板教程,mysql数据库帮助文档,公司dns服务器,dede 插件 下载,前端dp框架,脑爬虫,php类变量,天天seo伪原创,腾讯springboot文件,dz模板标签大全,jsp班级网站模板,网页 水波纹,珠宝玉器网站模板,后台联动标签如何调用,h5签到页面 源码,员工档案管理系统asp,时时彩源码程序破解lzw
客户端创建一个Socket并请求和服务器端链接
服务器端接受客户端请求，创建socekt与该客户端建立专线链接
建立链接的socket在一个单独的线程上对话
服务器继续等待新的链接
服务器端Server.java
package test.concurrent.socket; import java.io.*; import .InetAddress; import .ServerSocket; import .Socket; /** * Created by dong on 15-6-22. * 基于TCP协议的Socket通信，实现用户登录 * 服务器端 */public class Server {public static void main(String[] args) { try { //1、创建一个服务器端Socket,即ServerSocket, 指定绑定的端口，并监听此端口 ServerSocket serverSocket = new ServerSocket(8888); Socket socket = null; //记录客户端的数量 int count = 0; System.out.println("***服务器即将启动，等待客户端的链接***"); //循环监听等待客户端的链接 while (true){ //调用accept()方法开始监听，等待客户端的链接 socket = serverSocket.accept(); //创建一个新的线程 ServerThread serverThread = new ServerThread(socket); //启动线程 serverThread.start(); count++; //统计客户端的数量 System.out.println("客户端的数量: " + count); InetAddress address = socket.getInetAddress(); System.out.println("当前客户端的IP ： " + address.getHostAddress()); } } catch (IOException e) { e.printStackTrace();} } }
服务器端线程处理类ServerThread.java
package test.concurrent.socket; import java.io.*; import .Socket; /** * Created by dong on 15-6-22. * 服务器端线程处理类 */public class ServerThread extends Thread {//和本线程相关的Socket Socket socket = null; public ServerThread(Socket socket){this.socket = socket; }//线程执行的操作，响应客户端的请求 public void run(){ InputStream is = null;InputStreamReader isr = null;BufferedReader br = null; OutputStream os = null;PrintWriter pw = null;try { //获取一个输入流，并读取客户端的信息 is = socket.getInputStream(); isr = new InputStreamReader(is); //将字节流转化为字符流 br = new BufferedReader(isr); //添加缓冲 String info = null; //循环读取数据 while ((info = br.readLine()) != null){ System.out.println("我是服务器，客户端说: " +info); } socket.shutdownInput(); //关闭输入流 //获取输出流，响应客户端的请求 os = socket.getOutputStream(); pw = new PrintWriter(os); //包装为打印流 pw.write("欢迎你"); pw.flush(); //将缓存输出 } catch (IOException e) { e.printStackTrace();}finally { try { //关闭资源 if (pw != null) pw.close(); if (os != null) os.close(); if (is != null) is.close(); if (isr != null) isr.close(); if (br != null) br.close(); if (socket != null) socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
客户端Client.java
package test.concurrent.socket; import java.io.*; import .Socket; /** * Created by dong on 15-6-22. * 客户端 */public class Client {public static void main(String[] args) { try { //1、创建客户端Socket，指定服务器端口号和地址 Socket socket = new Socket("localhost",8888); //2、获取输出流,向服务器发送信息 OutputStream os = socket.getOutputStream(); //字节输出流 PrintWriter pw = new PrintWriter(os); //将输出流包装为打印流 pw.write("用户名:tom; 密码：456"); pw.flush(); socket.shutdownOutput(); //关闭输出流 InputStream is = socket.getInputStream(); InputStreamReader isr = new InputStreamReader(is); BufferedReader br = new BufferedReader(isr); String info = null; //循环读取 while ((info = br.readLine()) != null){ System.out.println("我是客户端:服务器说:" + info); } br.close(); is.close(); isr.close(); pw.close(); os.close(); socket.close();} catch (IOException e) { e.printStackTrace();} } }
更多java多线程实现服务器端与多客户端之间的通信相关文章请关注PHP中文网！
