服务器代码
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8901);
System.out.println("服务器已启动,等待连接......");
Socket socket = serverSocket.accept();
System.out.println("【客户端】:" + socket.getPort() + "已成功建立连接");
DataInputStream inputStream = new DataInputStream(socket.getInputStream());
DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
outputStream.writeUTF("与服务器建立连接【成功】");
String fromClientMsg = inputStream.readUTF();
System.out.println("【客户端】:" + fromClientMsg);
outputStream.writeUTF("【服务器】:成功接收消息【" + fromClientMsg + "】");
socket.close();
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
客户端代码
public static void main(String[] args) {
System.out.println("客户端已启动,正在连接......");
try {
Socket socket = new Socket("localhost", 8089);
DataInputStream inputStream = new DataInputStream(socket.getInputStream());
DataOutputStream outputStream = new DataOutputStream(socket.getOutputStream());
String fromServerMsg = inputStream.readUTF();
System.out.println(fromServerMsg);
Scanner scanner = new Scanner(System.in);
String clientMsg = scanner.nextLine();
outputStream.writeUTF(clientMsg);
System.out.println(inputStream.readUTF());
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}



