### 一、首先我们要准备一张表首先创建User_Token表记录一下啊谁扫码，谁登录字段如下： 1. uuid：用于确保唯一性 2. userld：谁登入的 3. loginTime：登录时间 4. createTime：创建时间用于判断是否过期 5. state：是否二维码失效 0有效 1失效 ### 二、角色都有哪些？扫码登录这个业务逻辑都有哪些角色 1. Android端或者微信Web端：扫码 2. PC端：被扫。登录 3. 服务端：掌控全局，提供接口。 ### 三、接口都需要哪些？ 1. 生成二维码接口：生成一个二维码。二维码中有UUId 2. 确认身份接口：确定身份以及判断是否二维码过期等。 ### 四、步骤 1. PC端打开。调用生成二维码接口并于服务端建立链接。链接使用 uuid 进行绑定。 2. 微信Web端进行扫码。获取二维码中的 uuid 。 3. 微信Web端拿到 uuid 以后。显示是否登录页面。点击确定后调用确认身份接口。 4. 确认身份接口通过以后。服务端给PC端发送信息。完成登录。此时链接断开。 ### 五、代码展示 **首先我们先要获取二维码** ```java // 登录二维码、放入Token @RequestMapping（value = "/getLoginQr" .method = RequsetMethod.Get) public void creatCodeImg(HttpServletRequset request, HttpServletResponse response){ response.setHeader("Pragma", "No-cache"); response.setHeader("Cache-Control", "no-cache"); response.setDateHeader("Expires", 0); response.setContentType("image/jpeg"); try{ //生成一个 uuid 插入数据库 String uuid = userService.createQrImg(); response.setHeader("uuid", uuid); QrCodeUtil.generate(uuid, 300, 300, "jpg", response.getOutputStream()); } catch { e.printStackTrace(); } } ``` > 有了获取二维码的接口。相对的前端需要调用。知识点：动态加载图片流出并取出 header 中的参数这里使用了xmlhttp 进行处理。因为后端获取的是数据流，这个数据流中放置了二维码中的 uuid 。这个 uuid 作为一次会话的标识符使用。那么前端也需要拿到。跟后端进行 webSocket 链接。这样有人扫码后。服务的才可以使用 webSocket 的方式通知前端。所以为了拿到请求中 header 中放置的 uuid 所以这样通过 xmlhttp 进行处理。 ```html

``` **上面已经提到了前端如何配置 webSocket 下面说一下 springBoot 中如何操作 webSocket** 1、增加 pom.xml ```xml org.springframework.boot spring-boot-starter-websocket ``` 2、加一个 Bean ```java @Bean public ServerEndpointExporter serverEndpointExporter() { return new ServerEndpointExporter(); } ``` 3、定义 WebSocketServer ```java package com.stylefeng.guns.rest.modular.inve.websocket; /** * Created by jiangjiacheng on 2019/6/4. */ import java.io.IOException; import java.util.concurrent.CopyOnWriteArraySet; 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 org.springframework.stereotype.Component; import cn.hutool.log.Log; import cn.hutool.log.LogFactory; @ServerEndpoint("/websocket/{sid}") @Component public class WebSocketServer { static Log log=LogFactory.get(WebSocketServer.class); //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。 private static int onlineCount = 0; //concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。 private static CopyOnWriteArraySet webSocketSet = new CopyOnWriteArraySet(); //与某个客户端的连接会话，需要通过它来给客户端发送数据 private Session session; //接收sid private String sid=""; /** * 连接建立成功调用的方法*/ @OnOpen public void onOpen(Session session,@PathParam("sid") String sid) { this.session = session; webSocketSet.add(this); //加入set中 addOnlineCount(); //在线数加1 log.info("有新窗口开始监听:"+sid+",当前在线人数为" + getOnlineCount()); this.sid=sid; /*try { sendMessage("连接成功"); } catch (IOException e) { log.error("websocket IO异常"); }*/ } /** * 连接关闭调用的方法 */ @OnClose public void onClose() { webSocketSet.remove(this); //从set中删除 subOnlineCount(); //在线数减1 log.info("有一连接关闭！当前在线人数为" + getOnlineCount()); } /** * 收到客户端消息后调用的方法 * * @param message 客户端发送过来的消息*/ @OnMessage public void onMessage(String message, Session session) { log.info("收到来自窗口"+sid+"的信息:"+message); //群发消息 for (WebSocketServer item : webSocketSet) { try { item.sendMessage(message); } catch (IOException e) { e.printStackTrace(); } } } /** * * @param session * @param error */ @OnError public void onError(Session session, Throwable error) { log.error("发生错误"); error.printStackTrace(); } /** * 实现服务器主动推送 */ public void sendMessage(String message) throws IOException { this.session.getBasicRemote().sendText(message); } /** * 群发自定义消息 * */ public static void sendInfo(String message,@PathParam("sid") String sid) throws IOException { log.info("推送消息到窗口"+sid+"，推送内容:"+message); for (WebSocketServer item : webSocketSet) { try { //这里可以设定只推送给这个sid的，为null则全部推送 if(sid == null) { item.sendMessage(message); }else if(item.sid.equals(sid)){ item.sendMessage(message); } } catch (IOException e) { continue; } } } public static synchronized int getOnlineCount() { return onlineCount; } public static synchronized void addOnlineCount() { WebSocketServer.onlineCount++; } public static synchronized void subOnlineCount() { WebSocketServer.onlineCount--; } } ``` 这样就增加了 webSocket 的支持啦。

他的文章