spring boot+vue+websocket带token身份认证推送消息实现.pdf-资料库

1、pom.xml文件添加依赖 org.springframework.boot spring-boot-starter-websocket 2、后台实现 WebSocketConfig.java站点配置 package com.huaxin.oe.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.server.standard.ServerEndpointExporter; @Configuration public class WebSocketConfig { @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); } } WebSocketServer.java服务端站点 package com.huaxin.oe.component.websocket; import com.huaxin.oe.base.RespMsg; import com.huaxin.oe.bean.Message; import lombok.extern.slf4j.Slf4j; import org.codehaus.jackson.map.ObjectMapper; import org.springframework.stereotype.Component; import javax.websocket.*; import javax.websocket.server.PathParam; import javax.websocket.server.ServerEndpoint; import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet; / * * * @ a u t h o r X i e K o n g * @ d a t e 2 0 1 8 / 6 / 2 2 1 1 : 3 4 * /

@ServerEndpoint("/websocket/{userId}") @Component @Slf4j public class WebSocketServer { private static int = 0; private static CopyOnWriteArraySet = new CopyOnWriteArraySet(); private Session session; private Integer userId = null; @OnOpen public void onOpen(Session session, @PathParam("userId") Integer userId) { this.session = session; .add(this); (); .info(" ID:" + userId + " , " + ()); / * * * @ a u t h o r X i e K o n g * @ d a t e 2 0 1 8 / 6 / 2 2 1 1 : 3 2 * / / * * * 静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。 * / o n l i n e C o u n t / * * * c o n c u r r e n t 包的线程安全 S e t ，用来存放每个客户端对应的 M y W e b S o c k e t 对象。 * / w e b S o c k e t S e t / * * * 与某个客户端的连接会话，需要通过它来给客户端发送数据 * / / * * * 接收 u s e r I d * / / * * * 连接建立成功调用的方法 * / / / 加入 s e t 中 w e b S o c k e t S e t / / 在线数加 1 a d d O n l i n e C o u n t l o g 用户连接成功当前在线人数为 g e t O n l i n e C o u n t

"); this.userId = userId; try { (userId, " } catch (IOException e) { e.printStackTrace(); } } .error("WebSocket IO "); @OnClose public void onClose() { .remove(this); (); .info(" :" + ()); } @OnMessage public void onMessage(String messageStr) { ObjectMapper mapper = new ObjectMapper(); try { Message message = mapper.readValue(messageStr, Message.class); } catch (Exception e) { e.printStackTrace(); } } .error("WebSocketServer onMessage", e); (message.getUserId(), message.getData()); s e n d M e s s a g e 消息服务器连接成功 l o g 异常 / * * * 连接关闭调用的方法 * / / / 从 s e t 中删除 w e b S o c k e t S e t / / 在线数减 1 s u b O n l i n e C o u n t l o g 有一连接关闭！当前在线人数为 g e t O n l i n e C o u n t / * * * 收到客户端消息后调用的方法 * * @ p a r a m m e s s a g e S t r 客户端发送过来的消息体 * / s e n d M e s s a g e l o g / * * * @ p a r a m s e s s i o n

@OnError public void onError(Session session, Throwable error) { error.printStackTrace(); } .error("WebSocketServer onError", error); public void sendMessage(String message) throws IOException { ObjectMapper mapper = new ObjectMapper(); this.session.getBasicRemote().sendText(mapper.writeValueAsString(new RespMsg(true, message))); } public static void sendMessage(Integer userId, String message) throws IOException { .info(" for (WebSocketServer item : :" + userId + " :" + message); ) { if (userId == null) { item.sendMessage(message); } else if (item.userId.equals(userId)) { item.sendMessage(message); break; } } } public static synchronized int getOnlineCount() { return } ; public static synchronized void addOnlineCount() { WebSocketServer. ++; * @ p a r a m e r r o r * / l o g / * * * 实现服务器主动推送 * / / * * * 消息推送接口，可以群发和指定用户推送 * / l o g 推送消息到用户，推送内容 w e b S o c k e t S e t / / 这里可以设定只推送给这个 u s e r I d 的，为 n u l l 则全部推送 o n l i n e C o u n t o n l i n e C o u n t

} public static synchronized void subOnlineCount() { WebSocketServer. } } --; Message.java发送消息体 package com.huaxin.oe.bean; public class Message { private Integer userId; private String data; public Message() { } public Message(Integer userId, String data) { this.userId = userId; this.data = data; } public Integer getUserId() { return userId; } public void setUserId(Integer userId) { this.userId = userId; } public String getData() { return data; } public void setData(String data) { o n l i n e C o u n t / * * * @ a u t h o r X i e K o n g * @ d a t e 2 0 1 8 / 6 / 2 5 1 5 : 5 5 * /

this.data = data; } } 3、前端 config下开发和生产环境全局配置添加 WS_URI: '"ws://localhost:8080/websocket/"' vue界面 4、测试消息发送 @ResponseBody @RequestMapping("/sendMessage") public RespMsg pushToWeb(@RequestParam("userId") Integer userId, @RequestParam("message") String message) { RespMsg respMsg = new RespMsg(); try { WebSocketServer. respMsg.setSuccess(true); } catch (IOException e) { e.printStackTrace(); respMsg.setSuccess(false); respMsg.setMessage(e.getMessage()); } return respMsg; } (userId, message); / / 数据接收 J S O N c o n s o l e / / w e b s o c k e t s e n d ( a g e n t D a t a ) { / / 数据发送 / / t h i s . w e b s o c k . s e n d ( a g e n t D a t a ) ; / / } , / / 关闭 c o n s o l e c o n s o l e s e n d M e s s a g e

资料库

spring boot+vue+websocket带token身份认证推送消息实现.pdf

相关推荐

开发技术

热门标签

最新资料