区块链技术博客
www.b2bchain.cn

标题: Java面向对象实现简单聊天室的问题,希望大哥大姐们帮我看看

b2bchain.cn区块链技术社区提供第11501篇技术文章标题: Java面向对象实现简单聊天室的问题,希望大哥大姐们帮我看看
问题解答:

Java面向对象实现简单聊天室的问题,希望大哥大姐们帮我看看

关于Java中sockets网络聊天室的简单实现。

“`
/*ChatClient.java*/
package cn.java.work.test6.Tcp;

import java.awt.Color;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import
import
import
import
import
import
import java.nio.channels.ServerSocketChannel;

import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JMenuBar;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.JWindow;

public class ChatClient extends JFrame implements ActionListener {

    /**
     *
     */
    private static final long serialVersionUID = 1L;
    JTextArea jTextArea; // 多行文本
    JLabel jlab1; // 标签
    JTextField jTextSend; // 单行文本
    JButton jButtonSend;// 按钮
    JLabel jlPort; // 端口 标签
    JTextField jtPort;
    JLabel jlIp;// 服务器 标签
    JTextField jtIp;
    JButton jButtonStart; // 启动服务器按钮
    JButton jButtonClear; // 清除聊天记录
    ServerSocket serverSocket; // 用于TCP通信前的连接
    Socket server; // TCP数据收发通信
    BufferedReader cin; // 字符输入
    PrintStream cout;

    public ChatClient() {
        this.setSize(600, 500);
        this.setVisible(true);
        this.setTitle("TCP聊天客户端");
        // 设置当前窗体 上的图形组件 手动布局
        this.setLayout(null);
        // 窗口加标签
        jlab1 = new JLabel("内容:");
        // jlab1.setSize(60, 20); // 标签图形 宽、高
        // jlab1.setLocation(20, 10);
        jlab1.setBounds(20, 10, 60, 20);
        jlab1.setVisible(true); // 标签可见,不隐藏
        this.add(jlab1);

        jTextArea = new JTextArea();
        jTextArea.setBounds(20, 40, 550, 300);
        // jTextArea.setBackground(Color.red); // 文本区 红色背景
        jTextArea.setVisible(true);
        this.add(jTextArea);
        // 单行文本
        jTextSend = new JTextField("");
        jTextSend.setBounds(20, 350, 470, 30);
        jTextSend.setVisible(true);
        // jTextSend.getText(); // 读取文本框内的字符串
        this.add(jTextSend);
        // 按钮 :发送
        jButtonSend = new JButton("发送");
        jButtonSend.setBounds(500, 350, 60, 30);
        jButtonSend.setVisible(true);
        // 给按钮 加 监视器/监听器
        jButtonSend.addActionListener(this);
        this.add(jButtonSend);
        // 加服务器标签
        jlPort = new JLabel("服务器");
        jlPort.setBounds(20, 390, 60, 30);
        jlPort.setVisible(true);
        this.add(jlPort);
        // 填IP号 的 文本框
        jtPort = new JTextField("127.0.0.1");
        jtPort.setBounds(70, 390, 60, 30);
        jtPort.setVisible(true);
        this.add(jtPort);
        // 加端口标签
        jlPort = new JLabel("端口");
        jlPort.setBounds(170, 390, 60, 30);
        jlPort.setVisible(true);
        this.add(jlPort);
        // 填端口号 的 文本框
        jtPort = new JTextField("8080");
        jtPort.setBounds(220, 390, 60, 30);
        jtPort.setVisible(true);
        this.add(jtPort);
        // 加 连接TCP聊天服务 按钮
        jButtonStart = new JButton("连接TCP服务器");
        jButtonStart.setBounds(340, 390, 125, 30);
        jButtonStart.setVisible(true);
        jButtonStart.addActionListener(this); // 监听 按钮
        this.add(jButtonStart);
        // 加 清除聊天屏幕 按钮
        jButtonClear = new JButton("清屏");
        jButtonClear.setBounds(500, 390, 60, 30);
        jButtonClear.setVisible(true);
        jButtonClear.addActionListener(this); // 监听按钮 单击事件
        this.add(jButtonClear);
        // 刷新窗体
        this.repaint();
    }

    // 实现事件处理方法:actionPerformed 鼠标单击事件处理
    public void actionPerformed(ActionEvent e) {
        if (e.getSource() == jButtonSend) {
            // 读取文本框的文本
            String strSend = jTextSend.getText();
            // 发送的文本填到 文本区对象
            jTextArea.append(strSend + "n");
            // 发送的文本填到 TCP === cout
            cout.println(strSend);
            // 发送文本框清零
            jTextSend.setText("");
        } else if (e.getSource() == jButtonClear) { // 清除按钮 事件处理
            // 清空文本区
            jTextArea.setText("");
        } else if (e.getSource() == jButtonStart) {
            // 启动TCP网络通信服务,等待客户端连接 重点!!
            try {
                String serverAddress = jtIp.getText();
                int port = Integer.parseInt(jtPort.getText());
                server = new Socket(serverAddress, port);
               
               
                // 1、服务器建立TCP连接控制对象
                serverSocket = new ServerSocket(port); // 服务器TCP端口是8080
                // 2、监听:等待 ,客户端连接,阻塞
                server = serverSocket.accept(); // 一旦有客户端主动连接我服务器,立即返回一个Socket对象
                // 3、TCP通信的数据流:连接执行到这里,说明 双方已经连接好了,可以通信了
                // server.getInputStream(); // TCP接收数据的字节流/管道
                // server.getOutputStream(); // TCP发送数据的字节流/管道
                // ——> 这一步,说明TCP连接就已经建立了
                // cin —–> 绑定 了TCP InputStream
                // cout —-> 绑定 了TCP OutputStream
                cin = new BufferedReader(new InputStreamReader(server.getInputStream()));
                cout = new PrintStream(server.getOutputStream());
                // 4、接收TCP数据 cin.readLine()
                // 向聊天记录文本区,加接收的字符串
                // jTextArea.append(cin.readLine());
                // 改进:多次接收,不定时===》 定义一个接收数据的 线程 === 一直等待接收数据,然后放入聊天区
                // 接收后做1件事:1、把数据放入聊天区
                ServerRec ServerReciver = new ServerRec(); //
                ServerReciver.start();
            } catch (IOException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
        }
    }

    // 服务器接收TCP数据的线程
    class ServerRec extends Thread {
        public void run() {
            while (true) {
                String recv;
                try {
                    // 1、读取一行字符串
                    recv = cin.readLine(); // 阻塞
                    // 2、把数据放入聊天区
                    jTextArea.append("服务器:" + recv + "n");
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) {
        new ChatClient();

    }

}
“`

“`
/*ChatServer.java*/
package cn.java.work.test6.Tcp;

import java.awt.Color;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import
import
import
import
import
import
import java.nio.channels.ServerSocketChannel;

import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JMenuBar;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.JWindow;

public class ChatServer extends JFrame implements ActionListener {

    /**
     *
     */
    private static final long serialVersionUID = 1L;
    JTextArea jTextArea; // 多行文本
    JLabel jlab1; // 标签
    JTextField jTextSend; // 单行文本
    JButton jButtonSend;// 按钮
    JLabel jlPort; // 端口 标签
    JTextField jtPort;
    JButton jButtonStart; // 启动服务器按钮
    JButton jButtonClear; // 清除聊天记录
    ServerSocket serverSocket; // 用于TCP通信前的连接
    Socket server; // TCP数据收发通信
    BufferedReader cin; // 字符输入
    PrintStream cout;

    public ChatServer() {
        this.setSize(600, 500);
        this.setVisible(true);
        this.setTitle("TCP聊天服务器");
        // 设置当前窗体 上的图形组件 手动布局
        this.setLayout(null);
        // 窗口加标签
        jlab1 = new JLabel("内容:");
        // jlab1.setSize(60, 20); // 标签图形 宽、高
        // jlab1.setLocation(20, 10);
        jlab1.setBounds(20, 10, 60, 20);
        jlab1.setVisible(true); // 标签可见,不隐藏
        this.add(jlab1);
        jTextArea = new JTextArea();
        jTextArea.setBounds(20, 40, 550, 300);
        // jTextArea.setBackground(Color.red); // 文本区 红色背景
        jTextArea.setVisible(true);
        this.add(jTextArea);
        // 单行文本
        jTextSend = new JTextField("");
        jTextSend.setBounds(20, 350, 470, 30);
        jTextSend.setVisible(true);
        // jTextSend.getText(); // 读取文本框内的字符串
        this.add(jTextSend);
        // 按钮 :发送
        jButtonSend = new JButton("发送");
        jButtonSend.setBounds(500, 350, 60, 30);
        jButtonSend.setVisible(true);
        // 给按钮 加 监视器/监听器
        jButtonSend.addActionListener(this);
        this.add(jButtonSend);
        // 加端口标签
        jlPort = new JLabel("端口");
        jlPort.setBounds(70, 390, 60, 30);
        jlPort.setVisible(true);
        this.add(jlPort);
        // 填端口号 的 文本框
        jtPort = new JTextField("8080");
        jtPort.setBounds(120, 390, 60, 30);
        jtPort.setVisible(true);
        this.add(jtPort);
        // 加 启动TCP聊天服务 按钮
        jButtonStart = new JButton("启动TCP服务器");
        jButtonStart.setBounds(240, 390, 125, 30);
        jButtonStart.setVisible(true);
        jButtonStart.addActionListener(this); // 监听 按钮
        this.add(jButtonStart);
        // 加 清除聊天屏幕 按钮
        jButtonClear = new JButton("清屏");
        jButtonClear.setBounds(500, 390, 60, 30);
        jButtonClear.setVisible(true);
        jButtonClear.addActionListener(this); // 监听按钮 单击事件
        this.add(jButtonClear);
        // 刷新窗体
        this.repaint();
    }

    // 实现事件处理方法:actionPerformed 鼠标单击事件处理
    public void actionPerformed(ActionEvent e) {
        if (e.getSource() == jButtonSend) {
            // 读取文本框的文本
            String strSend = jTextSend.getText();
            // 发送的文本填到 文本区对象
            jTextArea.append(strSend + "n");
            // 发送的文本填到 TCP === cout
            cout.println(strSend);
            // 发送文本框清零
            jTextSend.setText("");
        } else if (e.getSource() == jButtonClear) { // 清除按钮 事件处理
            // 清空文本区
            jTextArea.setText("");
        } else if (e.getSource() == jButtonStart) {
            // 启动TCP网络通信服务,等待客户端连接 重点!!
            try {
//                String serverAddress = jtIp.getText();
                int port = Integer.parseInt(jtPort.getText());
//                server = new Socket(serverAddress, port);
               
               
                // 1、服务器建立TCP连接控制对象
                serverSocket = new ServerSocket(port); // 服务器TCP端口是8080
                // 2、监听:等待 ,客户端连接,阻塞
                server = serverSocket.accept(); // 一旦有客户端主动连接我服务器,立即返回一个Socket对象
                // 3、TCP通信的数据流:连接执行到这里,说明 双方已经连接好了,可以通信了
                // server.getInputStream(); // TCP接收数据的字节流/管道
                // server.getOutputStream(); // TCP发送数据的字节流/管道
                // ——> 这一步,说明TCP连接就已经建立了
                // cin —–> 绑定 了TCP InputStream
                // cout —-> 绑定 了TCP OutputStream
                cin = new BufferedReader(new InputStreamReader(server.getInputStream()));
                cout = new PrintStream(server.getOutputStream());
                // 4、接收TCP数据 cin.readLine()
                // 向聊天记录文本区,加接收的字符串
                // jTextArea.append(cin.readLine());
                // 改进:多次接收,不定时===》 定义一个接收数据的 线程 === 一直等待接收数据,然后放入聊天区
                // 接收后做1件事:1、把数据放入聊天区
                ServerRec ServerReciver = new ServerRec(); //
                ServerReciver.start();
            } catch (IOException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
        }
    }

    // 服务器接收TCP数据的线程
    class ServerRec extends Thread {
        public void run() {
            while (true) {
                String recv;
                try {
                    // 1、读取一行字符串
                    recv = cin.readLine(); // 阻塞
                    // 2、把数据放入聊天区
                    jTextArea.append("客户端:" + recv + "n");
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) {
        new ChatServer();

    }

}
“`

一个是服务器的,一个是客户端的,图形界面已经设置了一些,但是怎么将服务器与客户端进行连通并实现简单聊天呢??需要热心的朋友们帮我看看并补充一些相关代码。非常感谢

标题: Java面向对象实现简单聊天室的问题,希望大哥大姐们帮我看看 由www.b2bchain.cn 提供
文章整理自网络,只为个人学习与分享使用
链接地址https://www.b2bchain.cn/?p=11501

赞(0) 打赏
部分文章转自网络,侵权联系删除b2bchain区块链学习技术社区 » 标题: Java面向对象实现简单聊天室的问题,希望大哥大姐们帮我看看
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

b2b链

联系我们联系我们