一对一聊天

2023-12-14 18:09:36

服务端

 

  1.  
    package 一对一用户;
     
  6.  
    import java.awt.BorderLayout;
     
  7.  
    import java.io.BufferedReader;
     
  8.  
    import java.io.IOException;
     
  9.  
    import java.io.InputStreamReader;
     
  10.  
    import java.io.PrintWriter;
     
  11.  
    import java.net.ServerSocket;
     
  12.  
    import java.net.Socket;
     
  13.  
    import java.util.Vector;
     
  14.  
    import javax.swing.JFrame;
     
  15.  
    import javax.swing.JScrollPane;
     
  16.  
    import javax.swing.JTextArea;
     
  18.  
    public class fuwuchuangkou extends JFrame {
     
  19.  
    private JTextArea ta_info;
     
  20.  
    private ServerSocket server; // 声明ServerSocket对象
     
  21.  
    private Socket socket; // 声明Socket对象socket
     
  22.  
    private Vector<Socket> vector = new Vector<Socket>();// 用于存储连接到服务器的客户端套接字对象
     
  24.  
    public void createSocket() {
     
  25.  
    try {
     
  26.  
    server = new ServerSocket(1978);
     
  27.  
    while (true) {
     
  28.  
    ta_info.append("等待新客户连接......\n");
     
  29.  
    socket = server.accept();// 创建套接字对象
     
  30.  
    vector.add(socket);// 将套接字对象添加到向量对象中
     
  31.  
    ta_info.append("客户端连接成功。" + socket + "\n");
     
  32.  
    new ServerThread(socket).start();// 创建并启动线程对象
     
  33.  
    }
     
  34.  
    } catch (IOException e) {
     
  35.  
    e.printStackTrace();
     
  36.  
    }
     
  37.  
    }
     
  39.  
    class ServerThread extends Thread {
     
  40.  
    Socket socket;
     
  41.  
    public ServerThread(Socket socket) {
     
  42.  
    this.socket = socket;
     
  43.  
    }
     
  44.  
    public void run() {
     
  45.  
    try {
     
  46.  
    BufferedReader in = new BufferedReader(new InputStreamReader(
     
  47.  
    socket.getInputStream()));// 创建输入流对象
     
  48.  
    while (true) {
     
  49.  
    String info = in.readLine();// 读取信息
     
  50.  
    for (Socket s : vector) {// 遍历所有客户端套接字对象
     
  51.  
    if (s != socket) {// 如果不是发送信息的套接字对象
     
  52.  
    PrintWriter out = new PrintWriter(s
     
  53.  
    .getOutputStream(), true);// 创建输出流对象
     
  54.  
    out.println(info);// 发送信息
     
  55.  
    out.flush();// 刷新输出缓冲区
     
  56.  
    }
     
  57.  
    }
     
  58.  
    }
     
  59.  
    } catch (IOException e) {
     
  60.  
    ta_info.append(socket + "已经退出。\n");
     
  61.  
    vector.remove(socket);// 移除退出的客户端套接字
     
  62.  
    }
     
  63.  
    }
     
  64.  
    }
     
  67.  
    public static void main(String args[]) {
     
  68.  
    fuwuchuangkou frame = new fuwuchuangkou();
     
  69.  
    frame.setVisible(true);
     
  70.  
    frame.createSocket();
     
  71.  
    }
     
  73.  
    /**
     
  74.  
    * Create the frame
     
  75.  
    */
     
  76.  
    public fuwuchuangkou() {
     
  77.  
    super();
     
  78.  
    setTitle("一对一");
     
  79.  
    setBounds(100, 100, 385, 266);
     
  80.  
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
     
  82.  
    final JScrollPane scrollPane = new JScrollPane();
     
  83.  
    getContentPane().add(scrollPane, BorderLayout.CENTER);
     
  85.  
    ta_info = new JTextArea();
     
  86.  
    scrollPane.setViewportView(ta_info);
     
  87.  
    }
     
  88.  
    }
     
 

 

 

客户端
 

 

  1.  
    package 一对一用户;
     
  4.  
    import java.awt.BorderLayout;
     
  5.  
    import java.awt.Dimension;
     
  6.  
    import java.awt.EventQueue;
     
  7.  
    import java.awt.event.ActionEvent;
     
  8.  
    import java.awt.event.ActionListener;
     
  9.  
    import java.io.BufferedReader;
     
  10.  
    import java.io.IOException;
     
  11.  
    import java.io.InputStreamReader;
     
  12.  
    import java.io.PrintWriter;
     
  13.  
    import java.net.Socket;
     
  14.  
    import java.net.UnknownHostException;
     
  15.  
    import javax.swing.JButton;
     
  16.  
    import javax.swing.JFrame;
     
  17.  
    import javax.swing.JLabel;
     
  18.  
    import javax.swing.JPanel;
     
  19.  
    import javax.swing.JScrollPane;
     
  20.  
    import javax.swing.JTextArea;
     
  21.  
    import javax.swing.JTextField;
     
  23.  
    public class kehuchuangkou extends JFrame {
     
  24.  
    private JTextArea ta_info;
     
  25.  
    private JTextField tf_send;
     
  26.  
    PrintWriter out;// 声明输出流对象
     
  28.  
    /**
     
  29.  
    * Launch the application
     
  30.  
    * 
     
  31.  
    * @param args
     
  32.  
    */
     
  33.  
    public static void main(String args[]) {
     
  34.  
    EventQueue.invokeLater(new Runnable() {
     
  35.  
    public void run() {
     
  36.  
    try {
     
  37.  
    kehuchuangkou frame = new kehuchuangkou();
     
  38.  
    frame.setVisible(true);
     
  39.  
    frame.createClientSocket();
     
  40.  
    } catch (Exception e) {
     
  41.  
    e.printStackTrace();
     
  42.  
    }
     
  43.  
    }
     
  44.  
    });
     
  45.  
    }
     
  47.  
    public void createClientSocket() {
     
  48.  
    try {
     
  49.  
    Socket socket = new Socket("127.0.0.1", 1978);// 连接本地1978端口
     
  50.  
    out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象
     
  51.  
    new ClientThread(socket).start();// 创建并启动线程对象
     
  52.  
    } catch (UnknownHostException e) {
     
  53.  
    e.printStackTrace();
     
  54.  
    } catch (IOException e) {
     
  55.  
    e.printStackTrace();
     
  56.  
    }
     
  57.  
    }
     
  59.  
    class ClientThread extends Thread {
     
  60.  
    Socket socket;
     
  62.  
    public ClientThread(Socket socket) {
     
  63.  
    this.socket = socket;
     
  64.  
    }
     
  66.  
    public void run() {
     
  67.  
    try {
     
  68.  
    BufferedReader in = new BufferedReader(new InputStreamReader(
     
  69.  
    socket.getInputStream()));// 创建输入流对象
     
  70.  
    while (true) {
     
  71.  
    String info = in.readLine();// 读取信息
     
  72.  
    ta_info.append(info + "\n");// 在文本域中显示信息
     
  73.  
    if (info.equals("88")) {
     
  74.  
    break;// 结束线程
     
  75.  
    }
     
  76.  
    }
     
  77.  
    } catch (IOException e) {
     
  78.  
    e.printStackTrace();
     
  79.  
    }
     
  80.  
    }
     
  81.  
    }
     
  82.  
    private void send() {
     
  83.  
    String info = tf_send.getText();// 获得输入的信息
     
  84.  
    if (info.equals("")) {
     
  85.  
    return;// 如果没输入信息则返回，即不发送
     
  86.  
    }
     
  87.  
    if (info.equals("88")) {
     
  88.  
    System.exit(0);// 如果没输入信息是88，则退出
     
  89.  
    }
     
  90.  
    out.println(info);// 发送信息
     
  91.  
    out.flush();// 刷新输出缓冲区
     
  92.  
    tf_send.setText(null);// 清空文本框
     
  93.  
    }
     
  96.  
    public kehuchuangkou() { //创建面板
     
  97.  
    super();
     
  98.  
    setTitle("一对一");
     
  99.  
    setBounds(100, 100, 385, 266);
     
  100.  
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
     
  102.  
    final JPanel panel = new JPanel();
     
  103.  
    getContentPane().add(panel, BorderLayout.SOUTH);
     
  105.  
    final JLabel label = new JLabel();
     
  106.  
    label.setText("输入聊天内容：");
     
  107.  
    panel.add(label);
     
  109.  
    tf_send = new JTextField();
     
  110.  
    tf_send.addActionListener(new ActionListener() {
     
  111.  
    public void actionPerformed(final ActionEvent e) {
     
  112.  
    send();
     
  113.  
    }
     
  114.  
    });
     
  115.  
    tf_send.setPreferredSize(new Dimension(180, 25));
     
  116.  
    panel.add(tf_send);
     
  118.  
    final JButton button = new JButton();
     
  119.  
    button.addActionListener(new ActionListener() {
     
  120.  
    public void actionPerformed(final ActionEvent e) {
     
  121.  
    send();
     
  122.  
    }
     
  123.  
    });
     
  124.  
    button.setText("发 送");
     
  125.  
    panel.add(button);
     
  127.  
    final JScrollPane scrollPane = new JScrollPane();
     
  128.  
    getContentPane().add(scrollPane, BorderLayout.CENTER);
     
  130.  
    ta_info = new JTextArea();
     
  131.  
    scrollPane.setViewportView(ta_info);
     
  133.  
    }
     
  135.  
    }
     
 

 

 

 

 

  1.  
    package 一对一用户;
     
  5.  
    import java.awt.BorderLayout;
     
  6.  
    import java.awt.Dimension;
     
  7.  
    import java.awt.EventQueue;
     
  8.  
    import java.awt.event.ActionEvent;
     
  9.  
    import java.awt.event.ActionListener;
     
  10.  
    import java.io.BufferedReader;
     
  11.  
    import java.io.IOException;
     
  12.  
    import java.io.InputStreamReader;
     
  13.  
    import java.io.PrintWriter;
     
  14.  
    import java.net.Socket;
     
  15.  
    import java.net.UnknownHostException;
     
  16.  
    import javax.swing.JButton;
     
  17.  
    import javax.swing.JFrame;
     
  18.  
    import javax.swing.JLabel;
     
  19.  
    import javax.swing.JPanel;
     
  20.  
    import javax.swing.JScrollPane;
     
  21.  
    import javax.swing.JTextArea;
     
  22.  
    import javax.swing.JTextField;
     
  24.  
    public class kehu1 extends JFrame {
     
  25.  
    private JTextArea ta_info;
     
  26.  
    private JTextField tf_send;
     
  27.  
    PrintWriter out;// 声明输出流对象
     
  29.  
    /**
     
  30.  
    * Launch the application
     
  31.  
    * 
     
  32.  
    * @param args
     
  33.  
    */
     
  34.  
    public static void main(String args[]) {
     
  35.  
    EventQueue.invokeLater(new Runnable() {
     
  36.  
    public void run() {
     
  37.  
    try {
     
  38.  
    kehuchuangkou frame = new kehuchuangkou();
     
  39.  
    frame.setVisible(true);
     
  40.  
    frame.createClientSocket();
     
  41.  
    } catch (Exception e) {
     
  42.  
    e.printStackTrace();
     
  43.  
    }
     
  44.  
    }
     
  45.  
    });
     
  46.  
    }
     
  48.  
    public void createClientSocket() {
     
  49.  
    try {
     
  50.  
    Socket socket = new Socket("127.0.0.1", 1978);// 连接本地1978端口
     
  51.  
    out = new PrintWriter(socket.getOutputStream(), true);// 创建输出流对象
     
  52.  
    new ClientThread(socket).start();// 创建并启动线程对象
     
  53.  
    } catch (UnknownHostException e) {
     
  54.  
    e.printStackTrace();
     
  55.  
    } catch (IOException e) {
     
  56.  
    e.printStackTrace();
     
  57.  
    }
     
  58.  
    }
     
  60.  
    class ClientThread extends Thread {
     
  61.  
    Socket socket;
     
  63.  
    public ClientThread(Socket socket) {
     
  64.  
    this.socket = socket;
     
  65.  
    }
     
  67.  
    public void run() {
     
  68.  
    try {
     
  69.  
    BufferedReader in = new BufferedReader(new InputStreamReader(
     
  70.  
    socket.getInputStream()));// 创建输入流对象
     
  71.  
    while (true) {
     
  72.  
    String info = in.readLine();// 读取信息
     
  73.  
    ta_info.append(info + "\n");// 在文本域中显示信息
     
  74.  
    if (info.equals("88")) {
     
  75.  
    break;// 结束线程
     
  76.  
    }
     
  77.  
    }
     
  78.  
    } catch (IOException e) {
     
  79.  
    e.printStackTrace();
     
  80.  
    }
     
  81.  
    }
     
  82.  
    }
     
  83.  
    private void send() {
     
  84.  
    String info = tf_send.getText();// 获得输入的信息
     
  85.  
    if (info.equals("")) {
     
  86.  
    return;// 如果没输入信息则返回，即不发送
     
  87.  
    }
     
  88.  
    if (info.equals("88")) {
     
  89.  
    System.exit(0);// 如果没输入信息是88，则退出
     
  90.  
    }
     
  91.  
    out.println(info);// 发送信息
     
  92.  
    out.flush();// 刷新输出缓冲区
     
  93.  
    tf_send.setText(null);// 清空文本框
     
  94.  
    }
     
  97.  
    public kehu1() { //创建面板
     
  98.  
    super();
     
  99.  
    setTitle("一对一");
     
  100.  
    setBounds(100, 100, 385, 266);
     
  101.  
    setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
     
  103.  
    final JPanel panel = new JPanel();
     
  104.  
    getContentPane().add(panel, BorderLayout.SOUTH);
     
  106.  
    final JLabel label = new JLabel();
     
  107.  
    label.setText("输入聊天内容：");
     
  108.  
    panel.add(label);
     
  110.  
    tf_send = new JTextField();
     
  111.  
    tf_send.addActionListener(new ActionListener() {
     
  112.  
    public void actionPerformed(final ActionEvent e) {
     
  113.  
    send();
     
  114.  
    }
     
  115.  
    });
     
  116.  
    tf_send.setPreferredSize(new Dimension(180, 25));
     
  117.  
    panel.add(tf_send);
     
  119.  
    final JButton button = new JButton();
     
  120.  
    button.addActionListener(new ActionListener() {
     
  121.  
    public void actionPerformed(final ActionEvent e) {
     
  122.  
    send();
     
  123.  
    }
     
  124.  
    });
     
  125.  
    button.setText("发 送");
     
  126.  
    panel.add(button);
     
  128.  
    final JScrollPane scrollPane = new JScrollPane();
     
  129.  
    getContentPane().add(scrollPane, BorderLayout.CENTER);
     
  131.  
    ta_info = new JTextArea();
     
  132.  
    scrollPane.setViewportView(ta_info);
     
  134.  
    }
     
  136.  
    }
     
 

 

 

运行结果如下：
 

 

    		

    		

    			文章来源:https://blog.csdn.net/ycq8888/article/details/134852448

    			本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。