cn.jdevelops.sboot.websocket.core

类 SocketController

java.lang.Object

cn.jdevelops.sboot.websocket.core.SocketController

@RestController
public class SocketController
extends Object

websocket 基础接口

时间

2020-07-08 12:40

作者

tn

字段概要

字段

限定符和类型	字段和说明
WebSocketServer	webSocketServer

构造器概要

构造器

构造器和说明
SocketController(WebSocketServer webSocketServer)

方法概要

限定符和类型	方法和说明
Object	allUserAsyncSocket(String message) 给所有用户推送消息(异步)
Object	allUserSocket(String message) 给所有用户推送消息
Object	onlyUserAsyncSocket(String userName, String message) 给指定用户推送消息 (异步)
Object	onlyUserSocket(String userName, String message) 给指定用户推送消息
Object	sendInfoAsyncByLikeKey(String keyPrefix, String message) (异步) 使用 sendInfoByLikeKey 进行模糊匹配用户进行消息发送 匹配 keyPrefix 开头的 websocket 用户 给他们发送消息 （keyPrefix用户1, keyPrefix用户2）
Object	sendInfoByLikeKey(String keyPrefix, String message) 使用 sendInfoByLikeKey 进行模糊匹配用户进行消息发送 匹配 keyPrefix 开头的 websocket 用户 给他们发送消息 （keyPrefix用户1, keyPrefix用户2）

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

webSocketServer

public final WebSocketServer webSocketServer

构造器详细资料

SocketController

public SocketController(WebSocketServer webSocketServer)

方法详细资料

onlyUserSocket

@GetMapping(value="/only")
public Object onlyUserSocket(@RequestParam(value="userName")
                                                         String userName,
                                                         @RequestParam(value="message")
                                                         String message)

给指定用户推送消息

参数

用户名, 消息

onlyUserAsyncSocket

@GetMapping(value="/only/async")
public Object onlyUserAsyncSocket(@RequestParam(value="userName")
                                                                    String userName,
                                                                    @RequestParam(value="message")
                                                                    String message)

给指定用户推送消息 (异步)

参数

用户名, 消息

allUserSocket

@GetMapping(value="/all")
public Object allUserSocket(@RequestParam(value="message")
                                                       String message)

给所有用户推送消息

参数

消息

allUserAsyncSocket

@GetMapping(value="/all/async")
public Object allUserAsyncSocket(@RequestParam(value="message")
                                                                  String message)

给所有用户推送消息(异步)

参数

消息

sendInfoByLikeKey

@RequestMapping(value="/prefix")
public Object sendInfoByLikeKey(@RequestParam(value="keyPrefix")
                                                                  String keyPrefix,
                                                                  @RequestParam(value="message")
                                                                  String message)

使用 sendInfoByLikeKey 进行模糊匹配用户进行消息发送 匹配 keyPrefix 开头的 websocket 用户 给他们发送消息 （keyPrefix用户1, keyPrefix用户2）

参数

主键前缀, 消息

sendInfoAsyncByLikeKey

@RequestMapping(value="/prefix/async")
public Object sendInfoAsyncByLikeKey(@RequestParam(value="keyPrefix")
                                                                             String keyPrefix,
                                                                             @RequestParam(value="message")
                                                                             String message)

(异步) 使用 sendInfoByLikeKey 进行模糊匹配用户进行消息发送 匹配 keyPrefix 开头的 websocket 用户 给他们发送消息 （keyPrefix用户1, keyPrefix用户2）

参数

主键前缀, 消息