java程序实现聊天互动

Posted ASKANDANSWERS

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了java程序实现聊天互动相关的知识,希望对你有一定的参考价值。

 

ServerChat.java文件
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

//说明:如果一个类,需要有界面显示,那么该类就需要继承自JFrame,此时,该类就可以被称为一个"窗体类"
//1.定义JFrame 窗体中的组件
//2.在构造方法中初始化窗体的组件
//3.使用网络编程完成数据的传输(TCP,UDP 协议)
//4.实现"发送"按钮的监听点击事件
//需要注意:文本域拼接数据时,实现自己换行,不要在发送数据中使用System.lineSeparator()换行
//这样会导致bw.newLine()与System.lineSeparator()两个换行导致使用BufferedReader读取时,无法正确的辨别需要的换行
//5.实现"回车键"发送数据
public class ServerChat extends JFrame implements ActionListener, KeyListener {
    public static void main(String[] args) {
        //调用构造方法
        new ServerChat();
        System.out.println("11111");
    }

    //属性
    //文本域
    private JTextArea jta;
    //滚动条
    private JScrollPane jsp;
    //面板
    private JPanel jp;
    //文本框
    private JTextField jtf;
    //按钮
    private JButton jb;

    //输出流
    private BufferedWriter bw = null;

    //构造方法
    public ServerChat() {
        //初始化组件
        //文本域
        jta = new JTextArea();
        //注意:需要将文本域添加到滚动条中,实现滚动效果
        //滚动条
        jsp = new JScrollPane(jta);

        //面板
        jp = new JPanel();
        //文本框
        jtf = new JTextField(10);//文本框大小
        //按钮
        jb = new JButton("发送");//按钮名称
        //注意:需要将文本框与按钮添加到面板中
        jp.add(jtf);
        jp.add(jb);

        //注意:需要将滚动条和面板添加到窗体中
        this.add(jsp, BorderLayout.CENTER);
        this.add(jp,BorderLayout.SOUTH);//上北下南

        //注意:需要设置 标题、大小、位置、关闭、是否可见
        this.setTitle("聊天框 服务");//标题
        this.setSize(300,300);// 宽 高
        this.setLocation(300,300);// 水平 垂直
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//窗体关闭 程序退出
        this.setVisible(true);//是否可见

        /******************* TCP 服务端 start ****************************/
        //给"发送"按钮绑定一个监听点击事件
        jb.addActionListener(this);//让当前对象监听
        //给文本框绑定一个键盘点击事件
        jtf.addKeyListener(this);

        try {
            //1.创建服务端套接字
            ServerSocket serverSocket = new ServerSocket(8888);
            //2.等待客户端连接
            Socket socket = serverSocket.accept();
            //3.获取socket 通道的输入流(输入流是实现读取数据,一行一行读取)
            InputStream in = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(in));
            //4.获取socket 通道的输出流(输出流实现写出数据,也是写一行,换一行,刷新)
            OutputStream out = socket.getOutputStream();
            bw = new BufferedWriter(new OutputStreamWriter(out));

            //循环读取数据,并拼接到文本域中
            String line = null;
            while((line = br.readLine()) != null) {
                //将读取的数据拼接到文本域中显示
                jta.append(line + System.lineSeparator());//换行
            }
            //5.关闭serverSocket 通道
            serverSocket.close();
        } catch(IOException e) {
            e.printStackTrace();
        }

        /******************* TCP 服务端 end ****************************/

    }

    @Override
    public void actionPerformed(ActionEvent event) {
        //发送数据到socket通道中
        sendDataToSocket();
    }

    @Override
    public void keyPressed(KeyEvent e) {
        if(e.getKeyCode() == KeyEvent.VK_ENTER) {
            //发送数据到socket通道中
            sendDataToSocket();
        }
    }
    @Override
    public void keyTyped(KeyEvent e) {
    }
    @Override
    public void keyReleased(KeyEvent e) {
    }

    //将数据发送到socket通道中
    private void sendDataToSocket(){
        //1.获取文本框中发送的内容
        String text = jtf.getText();
        //2.拼接需要发送的数据内容
        text = "服务:" + text;
        //3.在自己文本域中显示
        jta.append(text + System.lineSeparator());

        try {
            //4.发送
            bw.write(text);
            bw.newLine();
            bw.flush();
            //5.清空文本框内容
            jtf.setText("");

        } catch (IOException el) {
            el.printStackTrace();
        }
    }
}

  

ClientChat.java文件
import javax.swing.*;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyEvent;
import java.awt.event.KeyListener;
import java.io.*;
import java.net.Socket;

//说明:如果一个类,需要有界面显示,那么该类就需要继承自JFrame,此时,该类就可以被称为一个"窗体类"
//1.定义JFrame 窗体中的组件
//2.在构造方法中初始化窗体的组件
//3.使用网络编程完成数据的传输(TCP,UDP 协议)
//4.实现"发送"按钮的监听点击事件
//5.实现"回车键"发送数据
public class ClientChat extends JFrame implements ActionListener, KeyListener {
    public static void main(String[] args) {
        //调用构造方法
        new ClientChat();
    }

    //属性
    //文本域
    private JTextArea jta;
    //滚动条
    private JScrollPane jsp;
    //面板
    private JPanel jp;
    //文本框
    private JTextField jtf;
    //按钮
    private JButton jb;

    //输出流
    private BufferedWriter bw = null;

    //构造方法
    public ClientChat() {
        //初始化组件
        //文本域
        jta = new JTextArea();
        //注意:需要将文本域添加到滚动条中,实现滚动效果
        //滚动条
        jsp = new JScrollPane(jta);

        //面板
        jp = new JPanel();
        //文本框
        jtf = new JTextField(10);//文本框大小
        //按钮
        jb = new JButton("发送");//按钮名称
        //注意:需要将文本框与按钮添加到面板中
        jp.add(jtf);
        jp.add(jb);

        //注意:需要将滚动条和面板添加到窗体中
        this.add(jsp, BorderLayout.CENTER);
        this.add(jp,BorderLayout.SOUTH);//上北下南

        //注意:需要设置 标题、大小、位置、关闭、是否可见
        this.setTitle("聊天框 服务");//标题
        this.setSize(300,300);// 宽 高
        this.setLocation(700,300);// 水平 垂直
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//窗体关闭 程序退出
        this.setVisible(true);//是否可见

        /******************* TCP 服务端 start ****************************/
        //给"发送"按钮绑定一个监听点击事件
        jb.addActionListener(this);//让当前对象监听
        //给文本框绑定一个键盘点击事件
        jtf.addKeyListener(this);

        try {
            //1.创建服务端套接字
            Socket socket = new Socket("127.0.0.1",8888);
            //2.获取socket 通道的输入流(输入流是实现读取数据,一行一行读取)
            InputStream in = socket.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(in));
            //3.获取socket 通道的输出流(输出流实现写出数据,也是写一行,换一行,刷新)
            OutputStream out = socket.getOutputStream();
            bw = new BufferedWriter(new OutputStreamWriter(out));

            //循环读取数据,并拼接到文本域中
            String line = null;
            while((line = br.readLine()) != null) {
                //将读取的数据拼接到文本域中显示
                jta.append(line + System.lineSeparator());//换行
            }
            //4.关闭serverSocket 通道
            socket.close();
        } catch(IOException e) {
            e.printStackTrace();
        }

        /******************* TCP 服务端 end ****************************/

    }

    @Override
    public void actionPerformed(ActionEvent event) {
        //发送数据到socket通道中
        sendDataToSocket();
    }

    @Override
    public void keyPressed(KeyEvent e) {
        if(e.getKeyCode() == KeyEvent.VK_ENTER) {
            //发送数据到socket通道中
            sendDataToSocket();
        }
    }
    @Override
    public void keyTyped(KeyEvent e) {
    }
    @Override
    public void keyReleased(KeyEvent e) {
    }

    //将数据发送到socket通道中
    private void sendDataToSocket(){
        //1.获取文本框中发送的内容
        String text = jtf.getText();
        //2.拼接需要发送的数据内容
        text = "客户:" + text;
        //3.在自己文本域中显示
        jta.append(text + System.lineSeparator());

        try {
            //4.发送
            bw.write(text);
            bw.newLine();
            bw.flush();
            //5.清空文本框内容
            jtf.setText("");

        } catch (IOException el) {
            el.printStackTrace();
        }
    }
}

  




 

以上是关于java程序实现聊天互动的主要内容,如果未能解决你的问题,请参考以下文章

小程序如何集成即构IM实现即时通讯发消息聊天

Android:在视图/活动/片段之间滑动切换

IO多路复用互动聊天,select函数监听

java实现一个简单的网络聊天程序

一百行代码实现简易版 ChatGPT | 社区征文

怎么用QQ聊天,完整一点,我一窍不通。