超详细带你用Java实现QQ的聊天功能
个人名片:
🐼作者简介:一名在校生
🐻❄️个人主页:hmm.
🕊️系列专栏:零基础学java ----- 重识c语言
🐓每日一句:只要还有明天,今天就永远是起跑点。
前言:🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊🎊
最近有许多小伙伴问小新有没有好用的刷题网站,想提升一下自我能力**</font>
>**经过小新缜密的思考与亲身体验,推荐超实用的**🎉(点击访问牛客网)🎉
>*里面用丰富的大厂面试真题、各类算法由易到难层层递进、专项题库应有尽有,还不快来体验体验**🎏🎏🎏
文章目录
- 第一步:完成界面搭建🐓
- 第二步:TPC通信的思路与步骤🐻❄️
-
- TCP协议🐶
- TCP 服务端 具体步骤(客户端类似)🐮
- TCP通信步骤代码实现:🐸
- 点击发送按钮实现数据的传输🐺
- 第三步:实现回车键发送数据(客户端类似)🐳
- 全部代码:🐲
-
第一步:完成界面搭建🐓
要求:
- 创建两个窗口:一个客户端,一个服务端,完成代码书写
步骤:
1.定义JFrame窗体中的组件:文本域,滚动条,面板,文本框,按钮
//属性//文本域private JTextArea jta;//滚动条private JScrollPane jsp;//面板private JPanel jp;//文本框private JTextField jtf;//按钮private JButton jb; 2.在构造方法中初始化窗口的组件: //构造方法public ServerChatMain(){//初始化组件jta = new JTextArea();//设置文本域默认不可编辑jta.setEditable(false);//注意:需要将文本域添加到滚动条中,实现滚动效果jsp =new JScrollPane(jta);//初始化面板jp = new JPanel();jtf = new JTextField(10);jb=new JButton("发送");//注意:需要将文本框与按钮添加到面板中jp.add(jtf);jp.add(jb);4.设置设置”标题“,大小,位置,关闭,是否可见
//注意:需要设置”标题“,大小,位置,关闭,是否可见this.setTitle("QQ聊天服务端");this.setSize(400,300);this.setLocation(700,300);this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//窗体关闭,程序就退出this.setVisible(true);//设置窗体可见}这样我们就完成了服务端的QQ聊天界面窗口搭建:
注意:JTextArea文本域是不可以书写的
客户端与服务端代码类似,这里就不一一展示了
书写完毕代码,运行效果如下图:
第二步:TPC通信的思路与步骤🐻❄️
使用网络编程完成数据点的传输(TCP,UDP协议)
TCP协议🐶
TCP 是面向连接的运输层协议。应用程序在使用 TCP 协议之前,必须先建立 TCP 连接。在传送数据完毕后,必须释放已经建立的 TCP 连接
每一条 TCP 连接只能有两个端点,每一条 TCP 连接只能是点对点的(一对一)
TCP 提供可靠交付的服务。通过 TCP 连接传送的数据,无差错、不丢失、不重复,并且按序到达
TCP 提供全双工通信。TCP 允许通信双方的应用进程在任何时候都能发送数据。TCP 连接的两端都设有发送缓存和接受缓存,用来临时存放双向通信的数据
面向字节流。TCP 中的“流”指的是流入到进程或从进程流出的字节序列
TCP 服务端 具体步骤(客户端类似)🐮
具体步骤:
- 1.创建一个服务端的套接字
- 2.等待客户端连接
- 3.获取socket通道的输入流(输入六是实现读取数据的,一行一行读取)BufferedReader->readLine();
- 4.获取socket 通道的输出流(输出流实现写出数据,也是写一行换一行,刷新)BufferedWriter->newLine();
- 5.关闭socket 通道
TCP通信步骤代码实现:🐸
try {//1.创建一个服务端的套接字ServerSocket serverSocket = new ServerSocket(8888);//2.等待客户端连接Socket socket = serverSocket.accept();//3.获取socket通道的输入流(输入六是实现读取数据的,一行一行读取)BufferedReader->readLine();//InputStream in = socket.getInputStream();BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));//4.获取socket 通道的输出流(输出流实现写出数据,也是写一行换一行,刷新)BufferedWriter->newLine();//当用户点击发送按钮的时候写出数据BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//循环读取数据并拼接到文本域String line = null;while((line = br.readLine())!=null){//将读取的数据拼接到文本域中显示jta.append(line+System.lineSeparator());}//5.关闭socket 通道serverSocket.close();}catch (IOException e) {e.printStackTrace();}点击发送按钮实现数据的传输🐺
@Overridepublic void actionPerformed(ActionEvent actionEvent) {System.out.println("发送按钮被点击了");}步骤:
1.获取文本框中发送的内容
2.拼接需要发送的数据内容
3.自己也要显示
4.发送
5.清空文本框内容
第三步:实现回车键发送数据(客户端类似)🐳
首先要实现一个接口
public class ClientChatMain extends JFrame implements ActionListener, KeyListener { @Overridepublic void keyPressed(KeyEvent e) {//回车键// System.out.println(e);//发送数据到socket 同道中if(e.getKeyCode()==KeyEvent.VK_ENTER) {sendDataToSocket();}全部代码:🐲
服务端:
package com.ithmm.chat;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; import java.util.Properties;//说明:如果一个类,需要有界面的显示,那么这个类就需要继承JFrame,此时,该类可以被成为一个窗体类 /*步骤:1.定义JFrame窗体中的组件2.在构造方法中初始化窗口的组件3.使用网络编程完成数据的链接(TPC,UDP 协议)4.实现"发送”按钮的监听点击事件5.实现“回车键”发送数据*/ public class ServerChatMain extends JFrame implements ActionListener, KeyListener {public static void main(String[] args) {//调用构造方法new ServerChatMain();}//属性//文本域private JTextArea jta;//滚动条private JScrollPane jsp;//面板private JPanel jp;//文本框private JTextField jtf;//按钮private JButton jb;//输出流(成员变量)private BufferedWriter bw = null;//服务端的端口号//private static int serverPort;//使用static静态方法读取外部京台文件//static代码块特点:1.在类加载的时候自动执行//特点2:一个类会被加载一次,因此静态代码块在程序中仅会被执行一次/*static{Properties prop = new Properties();try {//加载prop.load(new FileReader("chat.properties"));//给属性赋值Integer.parseInt(prop.getProperty("serverPort"));} catch (IOException e) {e.printStackTrace();}}*///构造方法public ServerChatMain(){//初始化组件jta = new JTextArea();//设置文本域默认不可编辑jta.setEditable(false);//注意:需要将文本域添加到滚动条中,实现滚动效果jsp =new JScrollPane(jta);//初始化面板jp = new JPanel();jtf = new JTextField(10);jb=new JButton("发送");//注意:需要将文本框与按钮添加到面板中jp.add(jtf);jp.add(jb);//注意:需要将滚动条与面板全部添加到窗体中,继承了窗体的属性,这里this就是窗体this.add(jsp, BorderLayout.CENTER);//BorderLayout--边框布局this.add(jp,BorderLayout.SOUTH);//注意:需要设置”标题“,大小,位置,关闭,是否可见this.setTitle("QQ聊天服务端");this.setSize(400,300);this.setLocation(700,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通道的输入流(输入六是实现读取数据的,一行一行读取)BufferedReader->readLine();//InputStream in = socket.getInputStream();BufferedReader br=new BufferedReader(new InputStreamReader(socket.getInputStream()));//4.获取socket 通道的输出流(输出流实现写出数据,也是写一行换一行,刷新)BufferedWriter->newLine();//当用户点击发送按钮的时候写出数据bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//循环读取数据并拼接到文本域String line = null;while((line = br.readLine())!=null){//将读取的数据拼接到文本域中显示jta.append(line+System.lineSeparator());}//5.关闭socket 通道serverSocket.close();}catch (IOException e) {e.printStackTrace();}/**************** TCP 服务端 end *********************/}@Overridepublic void actionPerformed(ActionEvent actionEvent) {//System.out.println("发送按钮被点击了");sendDataToSocket();}//行为@Overridepublic void keyPressed(KeyEvent e) {//回车键// System.out.println(e);//发送数据到socket 同道中if(e.getKeyCode()==KeyEvent.VK_ENTER) {sendDataToSocket();}}//定义一个方法,实现将数据发送到socket通道中private void sendDataToSocket(){//1.获取文本框中发送的内容String text = jtf.getText();//2.拼接需要发送的数据内容text = "服务端对客户端说:"+text;//3.自己也要显示jta.append(text+System.lineSeparator());//4.发送try {bw.write(text);bw.newLine();//换行刷新bw.flush();//5.清空文本框内容jtf.setText("");} catch (IOException e) {e.printStackTrace();}}@Overridepublic void keyTyped(KeyEvent keyEvent) {}@Overridepublic void keyReleased(KeyEvent keyEvent) {}}客户端:
import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyEvent; import java.awt.event.KeyListener; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.Socket; import java.util.Properties;//说明:如果一个类,需要有界面的显示,那么这个类就需要继承JFrame,此时,该类可以被成为一个窗体类 /*步骤:1.定义JFrame窗体中的组件2.在构造方法中初始化窗口的组件*/public class ClientChatMain extends JFrame implements ActionListener, KeyListener {public static void main(String[] args) {//调用构造方法new ClientChatMain();}//属性//文本域private JTextArea jta;//滚动条private JScrollPane jsp;//面板private JPanel jp;//文本框private JTextField jtf;//按钮private JButton jb;//s输出流private BufferedWriter bw =null;//客户端的IP地址// private static String clientIp;//客户端的port端口号// private static int clientPort;//静态代码块加载外部配置文件/* static{Properties prop = new Properties();try {prop.load(new FileReader("chat.properties"));clientIp = prop.getProperty("clientIp");clientPort =Integer.parseInt( prop.getProperty("clientPort"));} catch (IOException e) {e.printStackTrace();}}*///构造方法public ClientChatMain(){//初始化组件jta = new JTextArea();//设置文本域默认不可编辑jta.setEditable(false);//注意:需要将文本域添加到滚动条中,实现滚动效果jsp =new JScrollPane(jta);//初始化面板jp = new JPanel();jtf = new JTextField(10);jb=new JButton("发送");//注意:需要将文本框与按钮添加到面板中jp.add(jtf);jp.add(jb);//注意:需要将滚动条与面板全部添加到窗体中,继承了窗体的属性,这里this就是窗体this.add(jsp, BorderLayout.CENTER);//BorderLayout--边框布局this.add(jp,BorderLayout.SOUTH);//注意:需要设置”标题“,大小,位置,关闭,是否可见this.setTitle("QQ聊天客户端");this.setSize(400,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通道的输入流BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));//3.获取socket 通道的输出流bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));//循环读取数据,并拼接到文本域String line = null;while((line = br.readLine())!=null){jta.append(line + System.lineSeparator());}//4.关闭socket 通道socket.close();}catch (Exception e){e.printStackTrace();}/**************** TCP 客户端 end *********************/}@Overridepublic void actionPerformed(ActionEvent e) {sendDataToSocket();}//行为@Overridepublic void keyPressed(KeyEvent e) {//回车键if(e.getKeyCode() == KeyEvent.VK_ENTER){//发送数据sendDataToSocket();}}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();bw.write(text);//5.清空jtf.setText("");} catch (IOException e) {e.printStackTrace();}}@Overridepublic void keyTyped(KeyEvent e) {}@Overridepublic void keyReleased(KeyEvent e) {}}接口类:
public interface addActistener { } public interface addActionListener { }
兄弟们,三连支持一下!!!
总结
以上是生活随笔为你收集整理的超详细带你用Java实现QQ的聊天功能的全部内容,希望文章能够帮你解决所遇到的问题。
- 上一篇: ext2.0中EditorGridPan
- 下一篇: Java实现QQ、微信、新浪微博第三方登