Socket支持下的点对点通信的实现（服务端与客户端注释）

服务端程序

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;

import javax.swing.*;

public class Server extends JFrame implements ActionListener {
	ServerSocket ss = null; // ServerSocket对象
	Socket s = null; // Socket对象
	private DataInputStream is = null; // 输入流
	private DataOutputStream os = null; // 输出流
	private boolean connected = false; // 是否连接标志
	JLabel ipLabel = new JLabel(); // 显示本机IP地址的标签
	JLabel portLabel = new JLabel("端口"); // 显示端口号的标签
	JTextField portTextField = new JTextField("8000"); // 端口号输入框
	JButton listenButton = new JButton("监听"); // 监听按钮
	JButton closeButton = new JButton("关闭"); // 关闭按钮
	JPanel panel = new JPanel(); // 包含各种控件的面板
	JTextField inputTextField = new JTextField(); // 输入框
	JTextArea contentTextArea = new JTextArea(); // 显示接收到的数据的文本区域
	Thread recvThread = new Thread(new RecvThread()); // 接收数据的线程

	// 构造函数
	public Server() {
		setTitle("服务器端"); // 窗口标题
		setLayout(new BorderLayout()); // 设置布局为边界布局
		panel.setLayout(new FlowLayout()); // 面板使用流式布局
		try {
			// 获取本机IP地址并显示
			ipLabel.setText("本机IP信息：" + InetAddress.getLocalHost().toString());
		} catch (HeadlessException e) {
			e.printStackTrace();
		} catch (UnknownHostException e) {
			e.printStackTrace();
		}
		panel.add(ipLabel); // 添加IP地址标签到面板
		panel.add(portLabel); // 添加端口号标签到面板
		panel.add(portTextField); // 添加端口号输入框到面板
		panel.add(listenButton); // 添加监听按钮到面板
		panel.add(closeButton); // 添加关闭按钮到面板
		add(panel, BorderLayout.NORTH); // 将面板添加到窗口北部
		add(new JScrollPane(contentTextArea), BorderLayout.CENTER); // 将文本区域添加到窗口中央，可以滚动
		add(inputTextField, BorderLayout.SOUTH); // 将输入框添加到窗口南部
		listenButton.addActionListener(this); // 监听按钮添加事件监听器
		closeButton.addActionListener(this); // 关闭按钮添加事件监听器
		inputTextField.addActionListener(this); // 输入框添加事件监听器

		addWindowListener(new WindowAdapter() { // 窗口关闭事件监听器，关闭程序时同时断开连接
			@Override
			public void windowClosing(WindowEvent e) {
				disconnect();
			}
		});
		setSize(500, 300); // 窗口大小
		setLocationRelativeTo(null); // 将窗口位于屏幕的中央
		setVisible(true); // 显示窗口
	}

	// 开始监听
	public void start() {
		try {
			int port = Integer.parseInt(portTextField.getText()); // 获取输入的端口号
			connected = true; // 标记已连接
			ss = new ServerSocket(port); // 创建ServerSocket对象
			s = ss.accept(); // 等待客户端连接
			os = new DataOutputStream(s.getOutputStream()); // 创建输出流
			is = new DataInputStream(s.getInputStream()); // 创建输入流
			recvThread.start(); // 启动接收数据的线程
		} catch (IOException e) {
		} finally {
			try {
				ss.close(); // 关闭ServerSocket
			} catch (IOException e) {
			}
		}
	}

	// 断开连接
	public void disconnect() {
		try {
			if (os != null)
				os.close(); // 关闭输出流
			if (is != null)
				is.close(); // 关闭输入流
			if (s != null)
				s.close(); // 关闭Socket
		} catch (IOException e) {
		}
		System.exit(0); // 退出程序
	}

	// 使用内部类创建接收数据线程
	private class RecvThread implements Runnable {
		public void run() {
			try {
				while (connected) { // 如果连接上了
					String str = is.readUTF(); // 接收客户端发送的数据
					contentTextArea.setText(contentTextArea.getText() + "client:" + str + '\n'); // 在文本区域显示接收到的数据
				}
			} catch (EOFException e) { // 客户端关闭了连接
				contentTextArea.setText("Client closed!");
			} catch (IOException e) {
				e.printStackTrace();
			}

		}
	}

	// 事件处理函数
	public void actionPerformed(ActionEvent e) {
		// 如果按下的是监听按钮
		if (e.getSource() == listenButton) {
			listenButton.setEnabled(false); // 禁用监听按钮
			start(); // 开始监听
		} else if (e.getSource() == closeButton) { // 如果按下的是关闭按钮
			disconnect(); // 断开连接
		} else if (e.getSource() == inputTextField) { // 如果按下的是输入框回车键
			String str = inputTextField.getText().trim(); // 获取输入框中的文本
			inputTextField.setText(""); // 清空输入框
			try {
				os.writeUTF(str); // 发送数据给客户端
				os.flush(); // 刷新输出流
				contentTextArea.setText(contentTextArea.getText() + "server:" + str + '\n'); // 在文本区域显示发送的数据
			} catch (IOException e1) {
			}
		}
	}

	// 主函数，创建窗口对象
	public static void main(String[] args) {
		new Server();
	}
}

客户端程序

import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;

import javax.swing.*;

public class Client extends JFrame implements ActionListener {
	Socket s = null; // Socket对象
	DataOutputStream os = null; // 输出流
	DataInputStream is = null; // 输入流
	private boolean connected = false; // 是否连接标志
	JLabel ipLabel = new JLabel("IP"); // 显示IP地址的标签
	JTextField ipTextField = new JTextField("127.0.0.1"); // IP地址输入框
	JLabel portLabel = new JLabel("端口"); // 显示端口号的标签
	JTextField portTextField = new JTextField("8000"); // 端口号输入框
	JButton connectButton = new JButton("连接"); // 连接按钮
	JButton closeButton = new JButton("关闭"); // 关闭按钮
	JPanel panel = new JPanel(); // 包含各种控件的面板
	JTextField inputTextField = new JTextField(); // 输入框
	JTextArea contentTextArea = new JTextArea(); // 显示接收到的数据的文本区域
	Thread recvThread = new Thread(new RecvThread()); // 接收数据的线程

	// 构造函数
	public Client() {
		setTitle("客户端"); // 窗口标题
		setLocation(400, 300); // 窗口位置
		setSize(500, 500); // 窗口大小
		setLayout(new BorderLayout()); // 设置布局为边界布局
		panel.setLayout(new FlowLayout()); // 面板使用流式布局
		panel.add(ipLabel); // 添加IP地址标签到面板
		panel.add(ipTextField); // 添加IP地址输入框到面板
		panel.add(portLabel); // 添加端口号标签到面板
		panel.add(portTextField); // 添加端口号输入框到面板
		panel.add(connectButton); // 添加连接按钮到面板
		panel.add(closeButton); // 添加关闭按钮到面板
		add(panel, BorderLayout.NORTH); // 将面板添加到窗口北部
		add(new JScrollPane(contentTextArea), BorderLayout.CENTER); // 将文本区域添加到窗口中央，可以滚动
		add(inputTextField, BorderLayout.SOUTH); // 将输入框添加到窗口南部
		connectButton.addActionListener(this); // 连接按钮添加事件监听器
		closeButton.addActionListener(this); // 关闭按钮添加事件监听器
		inputTextField.addActionListener(this); // 输入框添加事件监听器

		addWindowListener(new WindowAdapter() { // 窗口关闭事件监听器，关闭程序时同时断开连接
			@Override
			public void windowClosing(WindowEvent e) {
				disconnect();
			}
		});
		setSize(500, 300); // 窗口大小
		setLocationRelativeTo(null); // 将窗口位于屏幕的中央
		setVisible(true); // 显示窗口
	}

	// 连接服务器
	public void connect() {
		try {
			String host, port;
			host = ipTextField.getText(); // 获取输入的IP地址
			port = portTextField.getText(); // 获取输入的端口号
			s = new Socket(host, Integer.parseInt(port)); // 创建Socket对象并连接服务器
			os = new DataOutputStream(s.getOutputStream()); // 创建输出流
			is = new DataInputStream(s.getInputStream()); // 创建输入流
			connected = true; // 标记已连接
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	// 断开连接
	public void disconnect() {
		try {
			if (os != null)
				os.close(); // 关闭输出流
			if (is != null)
				is.close(); // 关闭输入流
			if (s != null)
				s.close(); // 关闭Socket
		} catch (IOException e) {
		}
		System.exit(0); // 退出程序
	}

	// 使用内部类创建接收数据线程
	private class RecvThread implements Runnable {
		public void run() {
			try {
				while (connected) { // 如果连接上了
					String str = is.readUTF(); // 接收服务器发送的数据
					contentTextArea.setText(contentTextArea.getText() + "server:" + str + '\n'); // 在文本区域显示接收到的数据
				}
			} catch (EOFException e) { // 服务器关闭了连接
				contentTextArea.setText("Server closed!");
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}

	// 事件处理函数
	public void actionPerformed(ActionEvent e) {
		if (e.getSource() == connectButton) { // 如果按下的是连接按钮
			connectButton.setEnabled(false); // 禁用连接按钮
			connect(); // 连接服务器
			recvThread.start(); // 启动接收数据的线程
		} else if (e.getSource() == closeButton) { // 如果按下的是关闭按钮
			disconnect(); // 断开连接
		} else if (e.getSource() == inputTextField) { // 如果按下的是输入框回车键
			String str = inputTextField.getText().trim(); // 获取输入框中的文本
			inputTextField.setText(""); // 清空输入框
			try {
				os.writeUTF(str); // 发送数据给服务器
				os.flush(); // 刷新输出流
				contentTextArea.setText(contentTextArea.getText() + "client:" + str + '\n'); // 在文本区域显示发送的数据
			} catch (IOException e1) {
			}
		}
	}

	// 主函数，创建窗口对象
	public static void main(String[] args) {
		new Client();
	}
}

本栏目推荐文章
• Django客户端应用1向服务端应用2发送POST请求并接收解析数据
• python socket服务端
• socket编程 [补档-2023-07-10]
• socket（四）Android与socket与LED灯
• 【Leetcode 2474. 购买量严格增加的客户】MySQL用户变量编程解决严格递增连续子序列问题
• 通过 KernelUtil.dll 劫持 QQ / TIM 客户端 QQClientkey / QQKey 详细教程（附源码）
• Windows 10 中，可以使用 PowerShell 添加打印和文件服务的角色功能组件，包括 Internet 打印客户端、LPD 打印服务和 LPR 端口监视器 PowerShell 添加打印机并创建新的 LPR 端口。以下是添加打印机和创建新端口的 PowerShell 命令在 Windows 10 中，可以使用 PowerShell 添加 LPR 兼容打印机。
• socket（三）串口与LED（stm32）
• 【MySQL】客户端命令
• Cisco Secure Client 5.1.1.42 (macOS, Linux, Windows & iOS, Andrord) - 思科安全客户端下载

注释 客户端 客户 Socket注释 客户端 客户socket 客户端winform客户socket 客户端 客户socket 客户端 客户socket demo 客户端 客户socket lyt-c 客户 服务器socket python 全局 客户端 客户socket 客户端 客户socket redis 客户端 客户 代码socket 客户端 消息 客户socket