TCP和UDP

package lx;
?
import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.*;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
?
public class ServerSocketFrame extends JFrame {
? ? private JTextField tf_send;
? ? private JTextArea ta_info;
? ? private PrintWriter writer; // 声明PrintWriter类对象
? ? private BufferedReader reader; // 声明BufferedReader对象
? ? private ServerSocket server; // 声明ServerSocket对象
? ? private Socket socket; // 声明Socket对象socket
? ??
? ? public void getServer() {
? ? ? ? try {
? ? ? ? ? ? server = new ServerSocket(1978); // 实例化Socket对象
? ? ? ? ? ? ta_info.append("服务器套接字已经创建成功\n"); // 输出信息
? ? ? ? ? ? while (true) { // 如果套接字是连接状态
? ? ? ? ? ? ? ? ta_info.append("等待客户机的连接......\n"); // 输出信息
? ? ? ? ? ? ? ? socket = server.accept(); // 实例化Socket对象
? ? ? ? ? ? ? ? reader = new BufferedReader(new InputStreamReader(socket
? ? ? ? ? ? ? ? ? ? ? ? .getInputStream())); // 实例化BufferedReader对象
? ? ? ? ? ? ? ? writer = new PrintWriter(socket.getOutputStream(), true);
? ? ? ? ? ? ? ? getClientInfo(); // 调用getClientInfo()方法
? ? ? ? ? ? }
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace(); // 输出异常信息
? ? ? ? }
? ? }
? ??
? ? private void getClientInfo() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? String line = reader.readLine();// 读取客户端发送的信息
? ? ? ? ? ? ? ? if (line != null)
? ? ? ? ? ? ? ? ? ? ta_info.append("接收到客户机发送的信息：" + line + "\n"); // 显示客户端发送的信息
? ? ? ? ? ? }
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ta_info.append("客户端已退出。\n"); // 输出异常信息
? ? ? ? } finally {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? if (reader != null) {
? ? ? ? ? ? ? ? ? ? reader.close();// 关闭流
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if (socket != null) {
? ? ? ? ? ? ? ? ? ? socket.close(); // 关闭套接字
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ??
? ? public static void main(String[] args) { // 主方法
? ? ? ? ServerSocketFrame frame = new ServerSocketFrame(); // 创建本类对象
? ? ? ? frame.setVisible(true);
? ? ? ? frame.getServer(); // 调用方法
? ? }
? ??
? ? public ServerSocketFrame() {
? ? ? ? super();
? ? ? ? setTitle("服务器端程序");
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ? setBounds(100, 100, 379, 260);
? ? ? ??
? ? ? ? final JScrollPane scrollPane = new JScrollPane();
? ? ? ? getContentPane().add(scrollPane, BorderLayout.CENTER);
? ? ? ??
? ? ? ? ta_info = new JTextArea();
? ? ? ? scrollPane.setViewportView(ta_info);
? ? ? ??
? ? ? ? final JPanel panel = new JPanel();
? ? ? ? getContentPane().add(panel, BorderLayout.SOUTH);
? ? ? ??
? ? ? ? final JLabel label = new JLabel();
? ? ? ? label.setText("服务器发送的信息：");
? ? ? ? panel.add(label);
? ? ? ??
? ? ? ? tf_send = new JTextField();
? ? ? ? tf_send.setPreferredSize(new Dimension(150, 25));
? ? ? ? panel.add(tf_send);
?
? ? ? ? final JButton button = new JButton();
? ? ? ? button.addActionListener(new ActionListener() {
? ? ? ? ? ? public void actionPerformed(final ActionEvent e) {
? ? ? ? ? ? ? ? writer.println(tf_send.getText()); // 将文本框中信息写入流
? ? ? ? ? ? ? ? ta_info.append("服务器发送的信息是：" + tf_send.getText() + "\n"); // 将文本框中信息显示在文本域中
? ? ? ? ? ? ? ? tf_send.setText(""); // 将文本框清空
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? button.setText("发 ?送");
? ? ? ? panel.add(button);
?
? ? ? ? final JPanel panel_1 = new JPanel();
? ? ? ? getContentPane().add(panel_1, BorderLayout.NORTH);
?
? ? ? ? final JLabel label_1 = new JLabel();
? ? ? ? label_1.setForeground(new Color(0, 0, 255));
? ? ? ? label_1.setFont(new Font("", Font.BOLD, 22));
? ? ? ? label_1.setText("一对一通信——服务器端程序");
? ? ? ? panel_1.add(label_1);
? ? }
}

package lx;
?
import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
?
import javax.swing.JButton;
?
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
?
public class ClientSocketFrame extends JFrame {
? ? private PrintWriter writer; // 声明PrintWriter类对象
? ? private BufferedReader reader; // 声明BufferedReader对象
? ? private Socket socket; // 声明Socket对象
? ? private JTextArea ta_info; // 创建JtextArea对象
? ? private JTextField tf_send; // 创建JtextField对象
? ? private void connect() { // 连接套接字方法
? ? ? ? ta_info.append("尝试连接......\n"); // 文本域中信息信息
? ? ? ? try { // 捕捉异常
? ? ? ? ? ? socket = new Socket("127.0.0.1", 1978); // 实例化Socket对象
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? writer = new PrintWriter(socket.getOutputStream(), true);
? ? ? ? ? ? ? ? reader = new BufferedReader(new InputStreamReader(socket
? ? ? ? ? ? ? ? ? ? ? ? .getInputStream())); // 实例化BufferedReader对象
? ? ? ? ? ? ? ? ta_info.append("完成连接。\n"); // 文本域中提示信息
? ? ? ? ? ? ? ? getServerInfo();
? ? ? ? ? ? }
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace(); // 输出异常信息
? ? ? ? }
? ? }
? ??
? ? public static void main(String[] args) { // 主方法
? ? ? ? ClientSocketFrame clien = new ClientSocketFrame(); // 创建本例对象
? ? ? ? clien.setVisible(true); // 将窗体显示
? ? ? ? clien.connect(); // 调用连接方法
? ? }
? ??
? ? private void getServerInfo() {
? ? ? ? try {
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? if (reader != null) {
? ? ? ? ? ? ? ? ? ? String line = reader.readLine();// 读取服务器发送的信息
? ? ? ? ? ? ? ? ? ? if (line != null)
? ? ? ? ? ? ? ? ? ? ? ? ta_info.append("接收到服务器发送的信息：" + line + "\n"); // 显示服务器端发送的信息
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? } catch (Exception e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } finally {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? if (reader != null) {
? ? ? ? ? ? ? ? ? ? reader.close();// 关闭流
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? if (socket != null) {
? ? ? ? ? ? ? ? ? ? socket.close(); // 关闭套接字
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ??
? ? /**
? ? ?* Create the frame
? ? ?*/
? ? public ClientSocketFrame() {
? ? ? ? super();
? ? ? ? setTitle("客户端程序");
? ? ? ? setBounds(100, 100, 361, 257);
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
?
? ? ? ? final JPanel panel = new JPanel();
? ? ? ? getContentPane().add(panel, BorderLayout.NORTH);
?
? ? ? ? final JLabel label = new JLabel();
? ? ? ? label.setForeground(new Color(0, 0, 255));
? ? ? ? label.setFont(new Font("", Font.BOLD, 22));
? ? ? ? label.setText("一对一通信——客户端程序");
? ? ? ? panel.add(label);
?
? ? ? ? final JPanel panel_1 = new JPanel();
? ? ? ? getContentPane().add(panel_1, BorderLayout.SOUTH);
?
? ? ? ? final JLabel label_1 = new JLabel();
? ? ? ? label_1.setText("客户端发送的信息：");
? ? ? ? panel_1.add(label_1);
?
? ? ? ? tf_send = new JTextField();
? ? ? ? tf_send.setPreferredSize(new Dimension(140, 25));
? ? ? ? panel_1.add(tf_send);
?
? ? ? ? final JButton button = new JButton();
? ? ? ? button.addActionListener(new ActionListener() {
? ? ? ? ? ? public void actionPerformed(final ActionEvent e) {
? ? ? ? ? ? ? ? writer.println(tf_send.getText()); // 将文本框中信息写入流
? ? ? ? ? ? ? ? ta_info.append("客户端发送的信息是：" + tf_send.getText()
? ? ? ? ? ? ? ? ? ? ? ? + "\n"); // 将文本框中信息显示在文本域中
? ? ? ? ? ? ? ? tf_send.setText(""); // 将文本框清空
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? button.setText("发 ?送");
? ? ? ? panel_1.add(button);
?
? ? ? ? final JScrollPane scrollPane = new JScrollPane();
? ? ? ? getContentPane().add(scrollPane, BorderLayout.CENTER);
?
? ? ? ? ta_info = new JTextArea();
? ? ? ? scrollPane.setViewportView(ta_info);
? ? ? ? //
? ? }
? ??
}

package lx;
?
import java.awt.BorderLayout;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
?
public class ClientOneToMany_ServerFrame extends JFrame {
? ? private JTextArea ta_info;
? ? private ServerSocket server; // 声明ServerSocket对象
? ? private Socket socket; // 声明Socket对象socket
? ? private Vector<Socket> vector = new Vector<Socket>();// 用于存储连接到服务器的客户端套接字对象
? ??
? ? public void createSocket() {
? ? ? ? try {
? ? ? ? ? ? server = new ServerSocket(1978);
? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? ta_info.append("等待新客户连接......\n");
? ? ? ? ? ? ? ? socket = server.accept();// 创建套接字对象
? ? ? ? ? ? ? ? vector.add(socket);// 将套接字对象添加到向量对象中
? ? ? ? ? ? ? ? ta_info.append("客户端连接成功。" + socket + "\n");
? ? ? ? ? ? ? ? new ServerThread(socket).start();// 创建并启动线程对象
? ? ? ? ? ? }
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ??
? ? class ServerThread extends Thread {
? ? ? ? Socket socket;
? ? ? ? public ServerThread(Socket socket) {
? ? ? ? ? ? this.socket = socket;
? ? ? ? }
? ? ? ? public void run() {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? BufferedReader in = new BufferedReader(new InputStreamReader(
? ? ? ? ? ? ? ? ? ? ? ? socket.getInputStream()));// 创建输入流对象
? ? ? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? ? ? String info = in.readLine();// 读取信息
? ? ? ? ? ? ? ? ? ? for (Socket s : vector) {// 遍历所有客户端套接字对象
? ? ? ? ? ? ? ? ? ? ? ? if (s != socket) {// 如果不是发送信息的套接字对象
? ? ? ? ? ? ? ? ? ? ? ? ? ? PrintWriter out = new PrintWriter(s
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? .getOutputStream(), true);// 创建输出流对象
? ? ? ? ? ? ? ? ? ? ? ? ? ? out.println(info);// 发送信息
? ? ? ? ? ? ? ? ? ? ? ? ? ? out.flush();// 刷新输出缓冲区
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? ta_info.append(socket + "已经退出。\n");
? ? ? ? ? ? ? ? vector.remove(socket);// 移除退出的客户端套接字
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ??
? ? /**
? ? ?* Launch the application
? ? ?*?
? ? ?* @param args
? ? ?*/
? ? public static void main(String args[]) {
? ? ? ? ClientOneToMany_ServerFrame frame = new ClientOneToMany_ServerFrame();
? ? ? ? frame.setVisible(true);
? ? ? ? frame.createSocket();
? ? }
? ??
? ? /**
? ? ?* Create the frame
? ? ?*/
? ? public ClientOneToMany_ServerFrame() {
? ? ? ? super();
? ? ? ? setTitle("客户端一对多通信——服务器端程序");
? ? ? ? setBounds(100, 100, 385, 266);
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ??
? ? ? ? final JScrollPane scrollPane = new JScrollPane();
? ? ? ? getContentPane().add(scrollPane, BorderLayout.CENTER);
? ? ? ??
? ? ? ? ta_info = new JTextArea();
? ? ? ? scrollPane.setViewportView(ta_info);
? ? }
}

UDP客户端：

package lx;
?
import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
?
public class ClientOneToMany_ClientFrame extends JFrame {
? ? private JTextArea ta_info;
? ? private JTextField tf_send;
? ? PrintWriter out;// 声明输出流对象
? ??
? ? /**
? ? ?* Launch the application
? ? ?*?
? ? ?* @param args
? ? ?*/
? ? public static void main(String args[]) {
? ? ? ? EventQueue.invokeLater(new Runnable() {
? ? ? ? ? ? public void run() {
? ? ? ? ? ? ? ? try {
? ? ? ? ? ? ? ? ? ? ClientOneToMany_ClientFrame frame = new ClientOneToMany_ClientFrame();
? ? ? ? ? ? ? ? ? ? frame.setVisible(true);
? ? ? ? ? ? ? ? ? ? frame.createClientSocket();
? ? ? ? ? ? ? ? } catch (Exception e) {
? ? ? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? });
? ? }
? ??
? ? public void createClientSocket() {
? ? ? ? try {
? ? ? ? ? ? Socket socket = new Socket("127.0.0.1", 1978);// 创建套接字对象
? ? ? ? ? ? out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象
? ? ? ? ? ? new ClientThread(socket).start();// 创建并启动线程对象
? ? ? ? } catch (UnknownHostException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? } catch (IOException e) {
? ? ? ? ? ? e.printStackTrace();
? ? ? ? }
? ? }
? ??
? ? class ClientThread extends Thread {
? ? ? ? Socket socket;
? ? ? ??
? ? ? ? public ClientThread(Socket socket) {
? ? ? ? ? ? this.socket = socket;
? ? ? ? }
? ? ? ??
? ? ? ? public void run() {
? ? ? ? ? ? try {
? ? ? ? ? ? ? ? BufferedReader in = new BufferedReader(new InputStreamReader(
? ? ? ? ? ? ? ? ? ? ? ? socket.getInputStream()));// 创建输入流对象
? ? ? ? ? ? ? ? while (true) {
? ? ? ? ? ? ? ? ? ? String info = in.readLine();// 读取信息
? ? ? ? ? ? ? ? ? ? ta_info.append(info + "\n");// 在文本域中显示信息
? ? ? ? ? ? ? ? ? ? if (info.equals("88")) {
? ? ? ? ? ? ? ? ? ? ? ? break;// 结束线程
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? } catch (IOException e) {
? ? ? ? ? ? ? ? e.printStackTrace();
? ? ? ? ? ? }
? ? ? ? }
? ? }
? ? private void send() {
? ? ? ? String info = tf_send.getText();// 获得输入的信息
? ? ? ? if (info.equals("")) {
? ? ? ? ? ? return;// 如果没输入信息则返回，即不发送
? ? ? ? }
? ? ? ? if (info.equals("88")) {
? ? ? ? ? ? System.exit(0);// 如果没输入信息是88，则退出
? ? ? ? }
? ? ? ? out.println(info);// 发送信息
? ? ? ? out.flush();// 刷新输出缓冲区
? ? ? ? tf_send.setText(null);// 清空文本框
? ? }
? ? /**
? ? ?* Create the frame
? ? ?*/
? ? public ClientOneToMany_ClientFrame() {
? ? ? ? super();
? ? ? ? setTitle("客户端一对多通信——客户端程序");
? ? ? ? setBounds(100, 100, 385, 266);
? ? ? ? setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
? ? ? ??
? ? ? ? final JPanel panel = new JPanel();
? ? ? ? getContentPane().add(panel, BorderLayout.SOUTH);
? ? ? ??
? ? ? ? final JLabel label = new JLabel();
? ? ? ? label.setText("输入聊天内容：");
? ? ? ? panel.add(label);
? ? ? ??
? ? ? ? tf_send = new JTextField();
? ? ? ? tf_send.addActionListener(new ActionListener() {
? ? ? ? ? ? public void actionPerformed(final ActionEvent e) {
? ? ? ? ? ? ? ? send();// 调用方法发送信息
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? tf_send.setPreferredSize(new Dimension(180, 25));
? ? ? ? panel.add(tf_send);
? ? ? ??
? ? ? ? final JButton button = new JButton();
? ? ? ? button.addActionListener(new ActionListener() {
? ? ? ? ? ? public void actionPerformed(final ActionEvent e) {
? ? ? ? ? ? ? ? send();// 调用方法发送信息
? ? ? ? ? ? }
? ? ? ? });
? ? ? ? button.setText("发 ?送");
? ? ? ? panel.add(button);
? ? ? ??
? ? ? ? final JScrollPane scrollPane = new JScrollPane();
? ? ? ? getContentPane().add(scrollPane, BorderLayout.CENTER);
? ? ? ??
? ? ? ? ta_info = new JTextArea();
? ? ? ? scrollPane.setViewportView(ta_info);
? ? ? ? //
? ? }
? ??
}