package com.test.demo; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Socket; import javax.swing.JTextField; public class ClientThread extends Thread { private Socket sk; private JTextField jtfa; public ClientThread(Socket sk,JTextField jtfa) { this.sk = sk; this.jtfa=jtfa; } @Override public void run() { while (true) { try { InputStream is = sk.getInputStream(); // 字节流转换为字符流量 InputStreamReader isr = new InputStreamReader(is); // 添加buffered BufferedReader br = new BufferedReader(isr); String str = br.readLine(); jtfa.setText(str); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }

这是一段 Java 代码，实现了一个客户端线程。客户端线程通过 Socket 连接与服务器通信，并接收服务器发送的消息。该线程使用了 Java 的 Socket API，通过建立 Socket 连接实现了客户端与服务器的通信。在 run 方法中，通过输入流接收服务器发送的消息并将其显示在客户端界面上。这段代码还接收了一个 JTextField 对象，用于在客户端界面上显示接收到的消息。