Java实现简单QQ聊天工具
更新时间：2022年09月16日 09:41:53 作者：发光吖
这篇文章主要为大家详细介绍了Java实现简单QQ聊天工具，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
Java实现简单的类似QQ聊天工具，供大家参考，具体内容如下
所使用到的知识点：
- java socket编程之TCP协议
- java Swing
- 简单的java多线程
运行截图：
服务器端实现：
package tcp_server;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;
/**
* @author 乔澳
* @version 1.0
* @title: ServerThread
* @projectName 20200222TCPServer
* @description:
* @date 2020/2/27 8:58
*/
public class ServerThread extends Thread{
private User user;
public ServerThread(User user){
this.user = user;
}
@Override
public void run() {
Map<String, User> userMap = Server.userMap;
Set<String> keys = userMap.keySet();
try {
BufferedReader reader = new BufferedReader(new InputStreamReader(user.getSocket().getInputStream()));
while (true) {
String value = reader.readLine();// 客户端发来的一句话
String[] valueAndUser = value.split("@");
//群聊
if (valueAndUser.length == 1) {
Iterator<String> it = keys.iterator();
while (it.hasNext()) {
String key = it.next();
User u = userMap.get(key);
PrintWriter pw = new PrintWriter(u.getSocket().getOutputStream());
pw.println(user.getUsername() + "：" + value + "(来自群消息)");
pw.flush();
}
} else {
//单聊
for (int i = 1; i < valueAndUser.length; i++) {
String username = valueAndUser[i];
User u = userMap.get(username);
PrintWriter pw = new PrintWriter(u.getSocket().getOutputStream());
pw.println(user.getUsername() + "：" + valueAndUser[0] + "(来自私聊)");
pw.flush();
}
}
}
} catch (IOException e) {
System.out.println(user.getUsername()+"下线了");
}
}
}package tcp_server;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.Map;
/**
* @author 乔澳
* @version 1.0
* @title: Server
* @projectName 20200222TCPServer
* @description:
* @date 2020/2/25 9:12
*/
public class Server {
static Map<String,User> userMap = new HashMap<String, User>();
public static void main(String[] args) {
try {
System.out.println("===server start===");
ServerSocket server = new ServerSocket(9999);
while(true) {
Socket socket = server.accept();
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String username = br.readLine();
User user = new User(username,socket);
System.out.println(user.getUsername()+"上线啦");
userMap.put(username,user);
ServerThread thread = new ServerThread(user);
thread.start();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}package tcp_server;
import java.net.Socket;
/**
* @author 乔澳
* @version 1.0
* @title: User
* @projectName 20200222TCPServer
* @description:
* @date 2020/2/27 8:23
*/
public class User {
public User(String username, Socket socket) {
this.username = username;
this.socket = socket;
}
private String username;
private Socket socket;
public User() {
}
public String getUsername() {
return username;
}
public Socket getSocket() {
return socket;
}
public void setUsername(String username) {
this.username = username;
}
public void setSocket(Socket socket) {
this.socket = socket;
}
}客户端实现：
package tcp_client;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
/**
* @author 乔澳
* @version 1.0
* @title: ClientReader
* @projectName 20200222TCPClient
* @description:
* @date 2020/2/26 16:11
*/
public class ClientReader extends Thread {
private Socket socket;
public ClientReader(Socket socket){
this.socket = socket;
}
public void run(){
try {
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader reader = new BufferedReader(isr);
for(;;){
String value = reader.readLine();
System.out.println(value);
}
} catch (IOException e) {
System.out.println("对不起，服务器崩溃了");
}
}
}package tcp_client;
import java.io.IOException;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
/**
* @author 乔澳
* @version 1.0
* @title: ClientWriter
* @projectName 20200222TCPClient
* @description:
* @date 2020/2/26 16:11
*/
public class ClientWriter extends Thread{
private Socket socket;
public ClientWriter(Socket socket){
this.socket = socket;
}
public void run(){
try {
Scanner input = new Scanner(System.in);
OutputStream os = socket.getOutputStream();
PrintWriter pw = new PrintWriter(os);
while(true) {
System.out.println("说点什么吧：");
String msg = input.nextLine();
pw.println(msg);
pw.flush();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}package tcp_client;
import javax.swing.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.Socket;
/**
* @author 乔澳
* @version 1.0
* @title: QQFrame
* @projectName 20200222TCPClient
* @description:
* @date 2020/2/28 9:46
*/
public class QQFrame extends JFrame{
private String name;
private JPanel panel = new JPanel();
private JTextArea mesgArea = new JTextArea();
private JScrollPane mesgPane = new JScrollPane(mesgArea);
private JTextArea speakArea = new JTextArea();
private JScrollPane speakPane = new JScrollPane(speakArea);
private JButton sendBtn = new JButton("发送");
private JButton resetBtn = new JButton("取消");
private Socket socket;
public QQFrame(String name){
super(name);
this.name = name;
this.initOther();
this.initElement();
this.initSelf();
this.connectServer();
this.startReader();
this.initListener();
}
private void connectServer(){
System.out.println("===client start===");
try {
socket = new Socket("127.0.0.1",9999);
PrintWriter pw = new PrintWriter(socket.getOutputStream());
pw.println(name);
pw.flush();
} catch (IOException e) {
JOptionPane.showMessageDialog(this,"服务器连接失败");
//e.printStackTrace();
}
}
private void startReader(){
//启动"读"线程
ClientReader reader = new ClientReader();
reader.start();
}
private void initListener(){
ActionListener listener = new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
try {
OutputStream os = socket.getOutputStream();
PrintWriter pw = new PrintWriter(os);
String msg = speakArea.getText();
if(msg.isEmpty())
return;
pw.println(msg);
pw.flush();
speakArea.setText("");
} catch (IOException ee) {
ee.printStackTrace();
}
}
};
sendBtn.addActionListener(listener);
resetBtn.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
speakArea.setText("");
}
});
}
private void initOther(){
panel.setLayout(null);
mesgArea.setEditable(false);
mesgPane.setBounds(10,10,305,220);
speakPane.setBounds(10,240,305,140);
sendBtn.setBounds(180,390,60,30);
resetBtn.setBounds(260,390,60,30);
}
private void initElement(){
panel.add(mesgPane);
panel.add(speakPane);
panel.add(sendBtn);
panel.add(resetBtn);
this.add(panel);
}
private void initSelf(){
this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
this.setBounds(1400,220,350,500);
this.setVisible(true);
}
public static void main(String[] args) {
new QQFrame("乔乔");
new QQFrame("小红");
new QQFrame("小明");
}
//内部类
public class ClientReader extends Thread {
StringBuffer sb = new StringBuffer();
public void run(){
try {
if(socket!=null) {
InputStream is = socket.getInputStream();
InputStreamReader isr = new InputStreamReader(is);
BufferedReader reader = new BufferedReader(isr);
for (; ; ) {
String value = reader.readLine();
sb.append(value + "\n");
mesgArea.setText(sb.toString());
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本文主要介绍了Java中sharding-jdbc按年月分片的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-07-07
今天和小伙伴们聊一聊 Spring AOP 中的代理对象是怎么创建出来的,透过这个过程再去熟悉一下 Bean 的创建过程,感兴趣的小伙伴跟着小编一起来看看吧2023-08-08
这篇文章主要介绍了Spring Boot 2.x基础教程之配置元数据的应用,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-01-01
这篇文章主要介绍了springBoot系列常用注解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-04-04
这篇文章主要介绍了Redis分布式锁实现方式及超时问题解决,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-04-04
spring boot使用sharding jdbc的配置方式
这篇文章主要介绍了spring boot使用sharding jdbc的配置方式，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-12-12
Synchronized是java虚拟机为线程安全而引入的。这篇文章主要为大家介绍一下Java关键词synchronized的使用与原理，需要的可以参考一下2022-12-12
这篇文章主要介绍了java前后端传值,参数有集合类型的数据时的两种操作方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2023-11-11
Springboot 实现跨域访问无需使用jsonp的实现代码
这篇文章主要介绍了Springboot 实现跨域访问 无需使用jsonp的实现代码，代码简单易懂，非常不错，具有一定的参考借鉴价值,需要的朋友可以参考下2018-09-09
在IT领域获取本机IP地址是一项基础但重要的任务,特别是在网络编程、远程协作和设备通信中,这篇文章主要给大家介绍了关于Java获取本机IP地址的方法(内网、公网),需要的朋友可以参考下2024-07-07
最新评论