是不是找了很多类似的博文都不能实现各个博主展示的效果呢?
原因在这我不谈,但是我保证,你看了这篇文章,只要你动手,那肯定有收获,没收获,那就是我蠢了
一、截图效果展示
有效果才有动力,这里我就先展示效果
服务端截图:
客户端截图:
群聊与私聊截图:
二、动图演示
这里我直接开了三个客户端,不会开的可以留言哈
客户端要定住它,不然它老是被切换,不会定的也可留言呀!!!
三、原理分析:(很重要呀呀)
- 首先要知道客户端与服务端的联系。
看我画的图:
说明分析:
- 流
1. 输出流:OutputStream(发送数据)
2. 输入流: InputStream(读取数据)
3. 如果这个知识点你都不是很了解,那就去补补IO流知识哈
- 服务器端
- 小伙伴们,这里你别把服务器端想的太过于复杂高大尚
- 这里其实就是一个类,它主要是用来存储数据、分发数据(我的理解)
- 然后就是一个无限循环,等待相应客户端,就这么简单哈
- 多人聊天
- 多人聊天意味着服务端要响应多个客户端,所以要在服务端开启无限循环模式
- 因为要多人聊天,所以就必须要加入多线程,不然就一直等待,直到某个客户端退出
- 需要一个容器来管理客户端,用它来进行各种操作(群发消息、私聊,系统消息)
- 群聊结构图
分析说明:
- 服务端通过receive方法(自己封装),获取数据
- 然后遍历容器,分发给除掉自身的socket,调用其send()方法(也需要自行封装)
四、撸代码(核心)
光说不练歪把子
代码都有详细的解释,我不信你看不懂,为了代码的可维护性,和整洁性,我将其进行了封装(其实就是各自写个函数、或者写成一个类而已,没有什么大不了的哈)
工具类:
package socket_study03;
import java.io.Closeable;
import java.io.IOException;
/**
* .工具类
* 用途:用于关闭各种流操作,封装一些代码
* @author 放牛娃学编程
*
*/
public class Utils {
//释放资源(后边带...,它代表可变参数)
public static void release(Closeable...targets)
{
for(Closeable target: targets)
{
try
{
if(null != target)
{
target.close();
}
}
catch(IOException e)
{
e.printStackTrace();
}
}
}
}
客户端:
package socket_study03;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.Socket;
/**
* 最终版:
* 1.用多线程实现客户端
* 2.读写分开
* 3.封装代码
*
* 功能:群聊、私聊
*
* 私聊格式说明:@xxx:msg
*
* @author 放牛娃学编程(公众号)
*
*/
//发送(写)线程类
class Send implements Runnable{
private BufferedReader console;
private DataOutputStream dos;
private Socket client;
private boolean flag;
private String name; //群聊时的备注
//构造器(用于数据初始化)
public Send(Socket client, String name)
{
this.client = client;
flag = true;
this.name = name;
console = new BufferedReader(new InputStreamReader(System.in));
try {
dos = new DataOutputStream(client.getOutputStream());
//先将自己的备注发过去(服务端)
send(name);
} catch (IOException e) {
// TODO Auto-generated catch block
this.release();
}
}
//从控制台获取数据
public String getFromConsole()
{
String msg = "";
try {
msg = console.readLine();
} catch (IOException e) {
// TODO Auto-generated catch block
release();
}
return msg;
}
//发送消息
public void send(String msg)
{
if(!msg.equals(""))
{
try
{
dos.writeUTF(msg);
dos.flush();
}
catch(IOException e)
{
e.printStackTrace();
}
}
}
//释放资源
public void release()
{
Utils.release(dos, client);
this.flag = false;
}
//线程体
@Override
public void run() {
// TODO Auto-generated method stub
while(flag)
{
//获取控制台输入的消息
String msg = getFromConsole();
//发送消息
send(msg);
}
}
}
//接收(消息)线程类
class Receive implements Runnable{
private DataInputStream dis;
private boolean flag;
private Socket client;
//构造器,用于对数据的初始化
public Receive(Socket client)
{
this.client = client;
flag = true;
try {
dis = new DataInputStream(client.getInputStream());
} catch (IOException e) {
// TODO Auto-generated catch block
this.release();
}
}
//接收消息
public void receive()
{
String msg = "";
try {
msg = dis.readUTF();
} catch (IOException e) {
// TODO Auto-generated catch block
release();
}
if(!msg.equals(""))
{
System.out.println(msg);
}
}
//释放资源
//释放资源
public void release()
{
Utils.release(dis, client);
this.flag = false;
}
//线程体
@Override
public void run() {
// TODO Auto-generated method stub
while(flag)
{
//接收消息
receive();
}
}
}
public class Client {
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
System.out.println("-------这是客户端-----------");
//获取控制台输入流
BufferedReader br = new BufferedReader(new java.io.InputStreamReader(System.in));
System.out.println("进入群聊前,请输入你的备注");
String name = br.readLine();
//获取socket管道
Socket client = new Socket(InetAddress.getLocalHost(), 9898);
//发送(写)线程
new Thread(new Send(client, name)).start();
//接收(读)线程
new Thread(new Receive(client)).start();
}
}
服务端:
限于篇幅这里我只给出主线程的代码(需要的自行提取)
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
System.out.println("-----这是服务端----------");
//获取ServerSocket管道
ServerSocket sSocket = new ServerSocket(9898);
while(true)
{
//获取客户端的socket
Socket client = sSocket.accept();
System.out.println("一个客户端连接成功");
Channel channel = new Channel(client);
//将每个客户端添加到容器中,进行统一管理
all.add(channel);
//启动线程
new Thread(channel).start();
}
}
五、 各种bug吐槽方案
- 直接复制这里的代码在eclipse中运行是报错的? 因为服务端的代码不全呀!!
- 如何获取服务端代码或者是整个项目? 关注公众号后回复:群聊项目。或者加我微信我亲自发你也行。
- 只需要服务端代码,如何获取? 点这就有了:Java聊天室----多线程实现群聊、私聊、系统消息 (服务端完整代码奉上)
- 小伙伴们,这个聊天项目测试通过,能够完成既定目标(群聊、私聊、系统回复)
如果遇到问题,没关系,多去折腾就完事了,也欢迎小伙伴们留言交流学习。
六、分享交流
最后有兴趣一起交流的,可以关注我的公众号:这里你能够学到很实用的技巧,不是常用的我不说,公众号回复提取码即可获取以下学习资料啦啦啦啦,喜欢就拿去吧!!
(链接时常会失效,若出现此类情况,可以加我微信:17722328325(加时请备注:学习资料))
-
Java web从入门到精通电子书
-
Python机器学习电子书
-
Python400集(北京尚学堂)
-
JavaScript项目案例、经典面试题
-
Java300集(入门、精通)
-
Java后端培训机构录集(同事培训内部提供)
-
IO流文档
-
JavaEE面试题及其参考答案文档
-
JavaSE面试题及其参考答案文档
-
java多线程技术文档
-
java网络编程文档
7~11都是之前同学花钱买来备战找实习的,需要的我也分享出去了。