gpt4 book ai didi

java - 多线程 Java TCP 客户端

转载 作者:太空宇宙 更新时间:2023-11-04 14:12:28 25 4
gpt4 key购买 nike

我正在编写一个 Java 客户端应用程序(带有 TCP/IP 的基本 Java Net 包)。客户端必须从 system.in 获取输入,同时必须通过套接字输入流监听来自服务器的任何消息。一旦收到来自 system.in 的输入,客户端将获取该输入,进行一些处理并将其作为请求发送到服务器。所以基本上有 2 个进程运行,

-监听客户端请求

-列出服务器响应。

我为此实现了 2 个线程,并在主线程中运行消息处理。这样的设计够好吗?

有没有办法将从system.in接收到的消息返回到主线程。线程的 run() 方法返回 void。我使用了 volatile 变量来返回收到的字符串,但据说 volatile 的成本非常高,因为它不使用 cpu 缓存来存储变量。

最佳答案

您可以查看我为 Java 套接字和多线程示例编写的这两个项目。

我猜 ClientExample 就是您正在寻找的那个,但您也可以看看服务器部分。

基本上,这个想法是启动两个单独的线程来监听不同的输入 - 套接字和控制台。

final Thread outThread = new Thread() {
@Override
public void run() {
System.out.println("Started...");
PrintWriter out = null;
Scanner sysIn = new Scanner(System.in);
try {
out = new PrintWriter(socket.getOutputStream());
out.println(name);
out.flush();

while (sysIn.hasNext() && !isFinished.get()) {
String line = sysIn.nextLine();
if ("exit".equals(line)) {
synchronized (isFinished) {
isFinished.set(true);
}
}
out.println(line);
out.flush();
disconnect();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
if (out != null) {
out.close();
}
}
};
};
outThread.start();

另一个用于套接字输入的线程:

        final Thread inThread = new Thread() {
@Override
public void run() {
// Use a Scanner to read from the remote server

Scanner in = null;
try {
in = new Scanner(socket.getInputStream());
String line = in.nextLine();
while (!isFinished.get()) {
System.out.println(line);
line = in.nextLine();
}
} catch (Exception e) {
// e.printStackTrace();
} finally {
if (in != null) {
in.close();
}
}
};
};
inThread.start();

希望这对你有帮助:)

关于java - 多线程 Java TCP 客户端,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28148060/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com