lywsvip/SpringBoot-Labs
1
0
Fork 0
mirror of https://gitee.com/yudaocode/SpringBoot-Labs.git synced 2026-09-03 05:53:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

增加 spring websocket 示例

Browse Source
This commit is contained in:
YunaiV
2019-11-21 01:50:41 +08:00
parent 11cd0db2c4
commit 77e0bce45c
4 changed files with 8 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lab-25/lab-websocket-25-02/src/main/java/cn/iocoder/springboot/lab25/springwebsocket/handler/AuthMessageHandler.java
View File

@@ -6,14 +6,13 @@ import cn.iocoder.springboot.lab25.springwebsocket.message.UserJoinNoticeRequest
import cn.iocoder.springboot.lab25.springwebsocket.util.WebSocketUtil;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;
import javax.websocket.Session;
import org.springframework.web.socket.WebSocketSession;
@Component
public class AuthMessageHandler implements MessageHandler<AuthRequest> {
@Override
public void execute(Session session, AuthRequest message) {
public void execute(WebSocketSession session, AuthRequest message) {
// 如果未传递 accessToken
if (StringUtils.isEmpty(message.getAccessToken())) {
WebSocketUtil.send(session, AuthResponse.TYPE,

5
lab-25/lab-websocket-25-02/src/main/java/cn/iocoder/springboot/lab25/springwebsocket/handler/MessageHandler.java
View File

@@ -1,8 +1,7 @@
package cn.iocoder.springboot.lab25.springwebsocket.handler;
import cn.iocoder.springboot.lab25.springwebsocket.message.Message;
import javax.websocket.Session;
import org.springframework.web.socket.WebSocketSession;
/**
* 消息处理器接口
@@ -15,7 +14,7 @@ public interface MessageHandler<T extends Message> {
* @param session 会话
* @param message 消息
*/
void execute(Session session, T message);
void execute(WebSocketSession session, T message);
/**
* @return 消息类型，即每个 Message 实现类上的 TYPE 静态字段

5
lab-25/lab-websocket-25-02/src/main/java/cn/iocoder/springboot/lab25/springwebsocket/handler/SendToAllHandler.java
View File

@@ -5,14 +5,13 @@ import cn.iocoder.springboot.lab25.springwebsocket.message.SendToAllRequest;
import cn.iocoder.springboot.lab25.springwebsocket.message.SendToUserRequest;
import cn.iocoder.springboot.lab25.springwebsocket.util.WebSocketUtil;
import org.springframework.stereotype.Component;
import javax.websocket.Session;
import org.springframework.web.socket.WebSocketSession;
@Component
public class SendToAllHandler implements MessageHandler<SendToAllRequest> {
@Override
public void execute(Session session, SendToAllRequest message) {
public void execute(WebSocketSession session, SendToAllRequest message) {
// 这里，假装直接成功
SendResponse sendResponse = new SendResponse().setMsgId(message.getMsgId()).setCode(0);
WebSocketUtil.send(session, SendResponse.TYPE, sendResponse);

5
lab-25/lab-websocket-25-02/src/main/java/cn/iocoder/springboot/lab25/springwebsocket/handler/SendToOneHandler.java
View File

@@ -5,14 +5,13 @@ import cn.iocoder.springboot.lab25.springwebsocket.message.SendToOneRequest;
import cn.iocoder.springboot.lab25.springwebsocket.message.SendToUserRequest;
import cn.iocoder.springboot.lab25.springwebsocket.util.WebSocketUtil;
import org.springframework.stereotype.Component;
import javax.websocket.Session;
import org.springframework.web.socket.WebSocketSession;
@Component
public class SendToOneHandler implements MessageHandler<SendToOneRequest> {
@Override
public void execute(Session session, SendToOneRequest message) {
public void execute(WebSocketSession session, SendToOneRequest message) {
// 这里，假装直接成功
SendResponse sendResponse = new SendResponse().setMsgId(message.getMsgId()).setCode(0);
WebSocketUtil.send(session, SendResponse.TYPE, sendResponse);