java socket 双向_java中用socket实现客户端与服务端双向连接问题

男娘i 2022-10-23 08:15 188阅读 0赞

展开全部

//服务端程序：

import java.io.\*;

import java.net.\*;

public class TCPServer \{

public static void main(String\[\] args) throws IOException \{

new TCPServer().init();

@e69da5e6ba9062616964757a686964616f31333335333661SuppressWarnings("static-access")

private void init() throws IOException\{

@SuppressWarnings("resource")

ServerSocket server = new ServerSocket(1000);

Socket client = null;

while(true)\{

try \{

client = server.accept();

BufferedInputStream bis = new BufferedInputStream(client.getInputStream());

byte\[\] b = new byte\[1024\];

int len = 0;

String message = "";

while((len=bis.read(b))!=-1)\{

message = new String(b,0,len);

System.out.print("客户端："+client.getInetAddress().getLocalHost().getHostAddress()+"发来消息：" + message);

if("byte".equals(message.trim()))

client.close();

PrintWriter pw = new PrintWriter(client.getOutputStream(),true);

pw.println(message);

\} catch (Exception e) \{

System.err.println("客户端："+client.getInetAddress().getLocalHost().getHostAddress()+" 已断开连接！");

\}//客户端程序：

import java.io.\*;

import java.net.Socket;

public class TCPClient implements Runnable\{

public static void main(String\[\] args) throws IOException \{

new TCPClient().init();

private void init() throws IOException\{

@SuppressWarnings("resource")

final Socket client = new Socket("127.0.0.1",1000);

BufferedReader in = new BufferedReader(new InputStreamReader(System.in));

String send = "";

while(true)\{

send = in.readLine();

PrintWriter out = new PrintWriter(client.getOutputStream(),true);

if(!"byte".equals(send.trim()))

out.println(send);

else\{

out.println(send);

System.exit(0);

new Thread(new TCPClient()\{

@SuppressWarnings("static-access")

public void run()\{

try \{

BufferedInputStream bis = new BufferedInputStream(client.getInputStream());

byte\[\] b = new byte\[1024\];

int len = 0;

while((len=bis.read(b))!=-1)\{

System.out.println("服务器：" +client.getInetAddress().getLocalHost().getHostAddress()+"发来消息："+new String(b,0,len).trim());

\} catch (IOException e) \{

System.err.println("连接服务器失败!");

\}).start();

public void run() \{\}

//服务器测试结果：

客户端：192.168.0.200发来消息：001 byte

客户端：192.168.0.200发来消息：byte

客户端：192.168.0.200 已断开连接！

客户端：192.168.0.200发来消息：adasd

客户端：192.168.0.200 已断开连接！

//客户端测试结果：

\---001号客户端--

001 byte

服务器：192.168.0.200发来消息：001 byte

byte //001礼貌说跟服务器说byte

\---002号客户端--

adasd //002客户端直接关闭程序

服务器：192.168.0.200发来消息：adasd

java socket 双向_java中用socket实现客户端与服务端双向连接问题

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Java Socket编程中客户端和服务器端连接问题实例

相关 Java网络编程：客户端Socket连接问题

相关 Java Socket编程中的客户端连接超时问题

相关 Java Socket框架Apache MINA实现Socket服务器-客户端双向即时消息通信

相关 Python连接Java Socket服务端

相关 java socket 双向_java中用socket实现客户端与服务端双向连接问题

相关客户端服务器端实现双向通信

相关 java socket长连接服务端

相关 Java Socket实现客户端与服务端通信实例

相关 php workman实现socket服务及客户端连接