Java学习笔记------一个能相互通信的半双工Socket C/S实例

叁歲伎倆 2022-08-03 11:56 153阅读 0赞

**服务器端代码：**

/\*  
\* 功能：是一个服务器，在9999端口上监听  
\* 可以通过控制台，输入会送给客户端的信息。  
\* 总共需要多少流？？？  
\* 1.把数据写入套接字流  
\* 2.从套接字中读取数据流  
\* 3.从控制台接收流  
\* 3.  
\*  
\*  
\* \*/  
  
  
package com.test1;  
import java.io.DataInputStream;  
import java.io.IOException;  
import java.net.\*;  
import java.io.\*;  
  
  
  
  
public class MyServer2  
\{  
public static void main(String\[\] args)  
\{  
MyServer2 ms2=new MyServer2();  
  
\}  
  
public MyServer2()  
\{  
try \{  
// 提示  
System.out.println("我正在9999监听。。。。");  
  
  
// 在9999端口上监听  
ServerSocket ss=new ServerSocket(9999);  
// 等待连接  
Socket s=ss.accept();  
  
// 先接收客户端发来的信息  
InputStreamReader isr=new InputStreamReader(s.getInputStream());  
  
BufferedReader br=new BufferedReader(isr);  
  
PrintWriter pw=new PrintWriter(s.getOutputStream(),true);  
  
// 接收从控制台输入的信息  
  
InputStreamReader isr2=new InputStreamReader(System.in);  
BufferedReader br2=new BufferedReader(isr2);// 这个流是用于读取Socket连接的。  
  
  
  
  
  
while(true)  
\{  
//  
  
  
  
String infoFromClient=br.readLine();  
//  
  
System.out.println("客户端发来："+infoFromClient);  
  
//接收从控制台输入的信息  
// 提示  
  
System.out.println("输入你希望对客户端说的话");  
String response =br2.readLine();  
// 把从控制台接收的信息，写入套接字  
pw.println(response);  
  
\}  
  
  
  
  
  
  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
\}  
\}

**客户端代码：**

**package com.test1;  
import java.net.\*;  
import java.io.\*;  
  
  
  
  
public class MyClient2  
\{  
public static void main(String\[\] args)  
\{  
MyClient2 mc2=new MyClient2();  
  
  
\}  
  
  
public MyClient2()  
\{  
try \{  
// 去连接服务器端  
Socket s=new Socket("127.0.0.1",9999);  
PrintWriter pw=new PrintWriter(s.getOutputStream(),true); // 刚才估计是因为，这个true 没写，才造成：客户端发送的数据，服务器端无法接收。  
// 客户端也需要一个流用于从控制台接收信息  
  
InputStreamReader isr=new InputStreamReader(System.in);  
BufferedReader br=new BufferedReader(isr);  
  
  
  
  
  
// 再创建一个流，用以从控制台  
InputStreamReader isr2=new InputStreamReader(s.getInputStream());  
BufferedReader br2=new BufferedReader(isr2);  
  
  
while(true)  
\{  
System.out.println("请输入你想对服务器说的话");  
// 客户端先从控制台接收  
String info =br.readLine();  
// 然后发送给服务器  
pw.println(info);  
// 接收从服务器发来的话  
  
  
  
String res= br2.readLine();  
System.out.println("服务器说："+res);  
\}  
  
\} catch (UnknownHostException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\} catch (IOException e) \{  
// TODO Auto-generated catch block  
e.printStackTrace();  
\}  
  
\}  
\}**