Java--Socket通信(客户端服务端双向)
发布时间:2020-12-14 14:21:02 所属栏目:Java 来源:网络整理
导读:新建两个工程,一个客户端,一个服务端,先启动服务端再启动客户端 两个工程的读写操作线程类基本上完全相同 服务端: import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; impo
新建两个工程,一个客户端,一个服务端,先启动服务端再启动客户端 两个工程的读写操作线程类基本上完全相同 服务端: import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class Server { public static final int PORT = 8000;//监听的端口号 public static void main(String[] args) { Server server = new Server(); server.init(); } public void init() { ServerSocket serverSocket = null; try { serverSocket = new ServerSocket(PORT); while (true) { Socket client = serverSocket.accept(); //一个客户端连接就开户两个线程处理读写 new Thread(new ReadHandlerThread(client)).start(); new Thread(new WriteHandlerThread(client)).start(); } } catch (Exception e) { e.printStackTrace(); } finally{ try { if(serverSocket != null){ serverSocket.close(); } } catch (IOException e) { e.printStackTrace(); } } } } /* *处理读操作的线程 */ class ReadHandlerThread implements Runnable{ private Socket client; public ReadHandlerThread(Socket client) { this.client = client; } @Override public void run() { DataInputStream dis = null; try{ while(true){ //读取客户端数据 dis = new DataInputStream(client.getInputStream()); String reciver = dis.readUTF(); System.out.println("客户端发过来的内容:" + reciver); } }catch(Exception e){ e.printStackTrace(); }finally{ try { if(dis != null){ dis.close(); } if(client != null){ client = null; } } catch (IOException e) { e.printStackTrace(); } } } } /* * 处理写操作的线程 */ class WriteHandlerThread implements Runnable{ private Socket client; public WriteHandlerThread(Socket client) { this.client = client; } @Override public void run() { DataOutputStream dos = null; BufferedReader br = null; try{ while(true){ //向客户端回复信息 dos = new DataOutputStream(client.getOutputStream()); System.out.print("请输入:t"); // 键盘录入 br = new BufferedReader(new InputStreamReader(System.in)); String send = br.readLine(); //发送数据 dos.writeUTF(send); } }catch(Exception e){ e.printStackTrace(); }finally{ try { if(dos != null){ dos.close(); } if(br != null){ br.close(); } if(client != null){ client = null; } } catch (IOException e) { e.printStackTrace(); } } } } 客户端: import java.io.BufferedReader; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.Socket; public class Client { public static final String IP = "localhost";//服务器地址 public static final int PORT = 8000;//服务器端口号 public static void main(String[] args) { handler(); } private static void handler(){ try { //实例化一个Socket,并指定服务器地址和端口 Socket client = new Socket(IP,PORT); //开启两个线程,一个负责读,一个负责写 new Thread(new ReadHandlerThread(client)).start(); new Thread(new WriteHandlerThread(client)).start(); } catch (Exception e) { e.printStackTrace(); } } } /* *处理读操作的线程 */ class ReadHandlerThread implements Runnable{ private Socket client; public ReadHandlerThread(Socket client) { this.client = client; } @Override public void run() { DataInputStream dis = null; try { while(true){ //读取服务器端数据 dis = new DataInputStream(client.getInputStream()); String receive = dis.readUTF(); System.out.println("服务器端返回过来的是: " + receive); } } catch (IOException e) { e.printStackTrace(); } finally{ try { if(dis != null){ dis.close(); } if(client != null){ client = null; } } catch (IOException e) { e.printStackTrace(); } } } } /* * 处理写操作的线程 */ class WriteHandlerThread implements Runnable{ private Socket client; public WriteHandlerThread(Socket client) { this.client = client; } @Override public void run() { DataOutputStream dos = null; BufferedReader br = null; try { while(true){ //取得输出流 dos = new DataOutputStream(client.getOutputStream()); System.out.print("请输入: t"); //键盘录入 br = new BufferedReader(new InputStreamReader(System.in)); String send = br.readLine(); //发送数据 dos.writeUTF(send); } } catch (IOException e) { e.printStackTrace(); } finally{ try{ if(dos != null){ dos.close(); } if(br != null){ br.close(); } if(client != null){ client = null; } }catch(Exception e){ e.printStackTrace(); } } } } 以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持编程小技巧。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
相关内容
- 如何在Java中使用regex拆分此String?
- 将嵌套对象属性绑定到JavaFx中的TableView
- java – Guice Jersey:添加所有的资源和提供者,而不需要绑
- java – 覆盖JTable的DefaultTableCellRenderer以使JTable中
- java – BASE64Encoder是内部API,可能会在将来的版本中删除
- java – NullPointerException onActivityCreated / onStar
- java – 如何获取项目中的类列表,该项目中的任何内容都不再
- java – Spring jdbcTemaplate如何一次性将完整的批量大小发
- java – 找不到符号类Intent
- 在Java中,如何测试“Double”列表是否包含特定值
推荐文章
站长推荐
- RESTful Web Services: A Tutorial--reference
- java – 让Selenium通过.htaccess popup登录
- 如果HashMap Java存在,它将获得值
- java 教你如何给你的头像添加一个好看的国旗
- java – 如何在apache http客户端中为所有请求设
- java – 如何使用RandomAccessFile读取UTF8编码文
- Eclipse中输入系统变量和运行参数--转
- java – ORA-24816:在实际LONG或LOB列之后提供的
- java – 如何在IntelliJ Idea中查看对象的完整类
- JDBC中使用Java8的日期LocalDate和LocalDateTime
热点阅读