Java入门TCP客户端和服务器应用步伐 2024.7.27 22:14 - ToB企服应用市场:ToB评测及商务社交产业平台

package gpt;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
private static final int port = 12345;//设置监听端口
public static void main(String[] args) {
System.out.println("服务器启动，等待客户端连接...");
try(ServerSocket serverSocket = new ServerSocket(port)) {
while (true)
{
Socket clientSocket = serverSocket.accept();
System.out.println("客户端已连接:" + clientSocket.getInetAddress());
//创建一个新的线程处理客户端请求
new ClientHandler(clientSocket).start();
}
} catch (Exception e) {
System.err.println("服务器异常: " + e.getMessage());
}
}
}
class ClientHandler extends Thread{
private Socket clientSocket;
public ClientHandler(Socket clientSocket) {
this.clientSocket = clientSocket;
}
@Override
public void run() {
try(BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {
String inputlines;
while((inputlines = in.readLine())!=null)
{
System.out.println("收到消息:" + inputlines);
out.println(inputlines.toUpperCase());//发送响应
}
} catch (Exception e) {
System.out.println("客户端处理异常" + e.getMessage());
}
finally {
try {
clientSocket.close();
} catch (IOException e) {
System.out.println("关闭异常连接" + e.getMessage());
}
}
}
}

复制代码

package gpt;
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class Client {
private static final String SERVER_ADDRESS = "localhost"; //服务器地址
private static final int SERVER_PORT = 12345; //服务器端口
public static void main(String[] args) {
try (Socket socket = new Socket(SERVER_ADDRESS, SERVER_PORT);
PrintWriter out = new PrintWriter(socket.getOutputStream(),true);
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
Scanner sc = new Scanner(System.in)) {
System.out.println("已连接到服务器，你可以开始聊天");
//新线程用于接收服务器消息
new Thread(() -> {
try {
String severMessage;
while((severMessage = in.readLine())!=null)
{
System.out.println("服务器：" + severMessage);
}
} catch (Exception e) {
System.out.println("接收消息时出错" + e.getMessage());
}
}
).start();
//主线程用于发送信息
String userInput;
while(true)
{
userInput = sc.nextLine();
if(userInput.equalsIgnoreCase("exit"))
{
break;
}
out.println(userInput);//发送信息
}
}
catch (Exception e)
{
System.err.println("连接服务器时出现异常: " + e.getMessage());
}
}
}

复制代码