JavaでQQチャットプログラムを作成する

以下に簡易的なJavaを用いたQQチャットプログラムのコード例を示す：

import java.io.*;
import java.net.*;
public class QQChatClient {
private Socket socket;
private BufferedReader reader;
private PrintWriter writer;
public QQChatClient(String host, int port) {
try {
// 连接服务器
socket = new Socket(host, port);
System.out.println("成功连接到服务器");
// 创建输入输出流
reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
writer = new PrintWriter(socket.getOutputStream(), true);
// 启动接收消息线程
new Thread(new MessageReceiver()).start();
// 读取用户输入并发送消息
BufferedReader userInputReader = new BufferedReader(new InputStreamReader(System.in));
String userInput;
while ((userInput = userInputReader.readLine()) != null) {
writer.println(userInput);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (socket != null) {
socket.close();
}
if (reader != null) {
reader.close();
}
if (writer != null) {
writer.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public static void main(String[] args) {
QQChatClient chatClient = new QQChatClient("localhost", 8888);
}
class MessageReceiver implements Runnable {
@Override
public void run() {
try {
String message;
while ((message = reader.readLine()) != null) {
System.out.println("收到消息：" + message);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}

指定のサーバとポートへSocketで接続し、入出力ストリームを作成してメッセージの送受信を行っている。メインスレッドでは、ユーザの入力を読み込み、サーバに送信している。また、別スレッドでは、入力ストリームからメッセージを受け取り、コンソールに出力している。