发布时间:2023-08-22 08:00
还记得之前我们用c#写过一个聊天室,但是是cs的,我们都知道现在流行的是bs架构,所以很相似C#用的是socket底层是tcp和udp而websocket其实就是在http的基础上模仿tcp和udp握手和挥手
基于C#的socket聊天室(附源码): https://blog.csdn.net/hello_list/article/details/124075029
原理嘛都差不多,要我说一个文章讲原理不如直接上例子上代码的方便,讲解一下这个小例子就懂了;
这里呢我们使用的是tomcat自带的依赖,所以不用导入,还有一种方法是spring的,这里就不说了;
我们先尝试体验下效果
将Web项目运行起来,一个特别简单的页面,其实页面我们可以去扒就可以,比如csdn的私信页面,拿去用就行,功能还那么个功能,但是我这里主要是功能,就没有扒页面,看完这个例子,完全可以去做一个csdn这样的私信功能;
先看下我这个简陋的页面
我们再看下功能,可简单了,会用吧
输入id点击获取连接;连接成功之后,这个时候id就固定了,我这里直接锁住了
我们再开两个,三个用户我们就连接成功了;
这里也可以看下后端日志
我们可以给在线的用户发送消息,只需要输入对方id,我这里就试着互相发了几条消息:
功能到这里就结束了,我们看下是怎么实现的,简单理解下,可简单了;
服务端代码,一个java文件就搞定
package servlet;
import java.io.IOException;
import java.util.Map;
import java.util.Scanner;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
@ServerEndpoint("/webSocket/{sid}")
public class TestWebSocket {
// 静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。
private static AtomicInteger onlineNum = new AtomicInteger();
// concurrent包的线程安全Set,用来存放每个客户端对应的WebSocketServer对象。
private static ConcurrentHashMap<String, Session> sessionPools = new ConcurrentHashMap<>();
// 发送消息
public void sendMessage(Session session, String message) throws IOException {
if (session != null) {
synchronized (session) {
// System.out.println("发送数据:" + message);
session.getBasicRemote().sendText(message);
}
}
}
@OnOpen
public void onOpen(Session session, @PathParam(value = "sid") String sid) throws IOException {
System.out.println("新连接");
sessionPools.put(sid, session);
addOnlineCount();
System.out.println(sid + "加入webSocket!当前人数为" + onlineNum);
sendMessage(session, "欢迎" + sid + "加入连接!");
}
@OnClose
public void onClose() {
subOnlineCount();
System.out.println("连接关闭");
}
@OnMessage
public void onMessage(String message, Session session) throws IOException {
System.out.println("收到消息");
System.out.println(message);
// session.getBasicRemote().sendText("你好,我是服务端");
JSONObject jsonObject = (JSONObject) JSON.parse(message);
System.out.println(jsonObject);
// sendMessage(sessionPools.get(jsonObject.get("tsid")), String.valueOf(jsonObject.get("sid"))+"--给你发来消息:"+String.valueOf(jsonObject.get("txt")));
// System.out.println( String.valueOf(jsonObject.get("sid"))+"发送消息成功");
JSONObject jsonObject2 = new JSONObject();
jsonObject2.put("fromid", String.valueOf(jsonObject.get("sid")));
jsonObject2.put("text", String.valueOf(jsonObject.get("txt")));
sendMessage(sessionPools.get(jsonObject.get("tsid")), jsonObject2.toJSONString());
}
@OnError
public void onError(Session session, Throwable error) {
error.printStackTrace();
}
// 增加在线人数
public static void addOnlineCount() {
onlineNum.incrementAndGet();
}
// 减少在线人数
public static void subOnlineCount() {
onlineNum.decrementAndGet();
}
}
所以说前后就两个文件,这里我们在客户端创建一个websocket然后去连接服务端即可;
Document
消息输入:
消息接收人的id:
以下是消息区域:
看到这里的同学都知道,博主就喜欢给大家留出优化空间,比如根据这个实现下csdn的私信功能,把页面拔下来都是现成的,对吧,所以都看到这里了,还不留个关注,点个赞吗,bye~