WebSocket

maven

1.                 <dependency>
2.             <groupId>org.springframework.boot</groupId>
3.             <artifactId>spring-boot-starter-websocket</artifactId>
4.         </dependency>

复制代码

配置类

1. package com.sky.config;
3. import org.springframework.context.annotation.Bean;
4. import org.springframework.context.annotation.Configuration;
5. import org.springframework.web.socket.server.standard.ServerEndpointExporter;
7. /**
8. * WebSocket配置类，用于注册WebSocket的Bean
9. */
10. @Configuration
11. public class WebSocketConfiguration {
13.     @Bean
14.     public ServerEndpointExporter serverEndpointExporter() {
15.         return new ServerEndpointExporter();
16.     }
18. }

复制代码

WebSocketServer

1. package com.sky.websocket;
3. import org.springframework.stereotype.Component;
4. import javax.websocket.OnClose;
5. import javax.websocket.OnMessage;
6. import javax.websocket.OnOpen;
7. import javax.websocket.Session;
8. import javax.websocket.server.PathParam;
9. import javax.websocket.server.ServerEndpoint;
10. import java.util.Collection;
11. import java.util.HashMap;
12. import java.util.Map;
14. /**
15. * WebSocket服务
16. */
17. @Component
18. @ServerEndpoint("/ws/{sid}")
19. public class WebSocketServer {
21.     //存放会话对象
22.     private static Map<String, Session> sessionMap = new HashMap();
24.     /**
25.      * 连接建立成功调用的方法
26.      */
27.     @OnOpen
28.     public void onOpen(Session session, @PathParam("sid") String sid) {
29.         System.out.println("客户端：" + sid + "建立连接");
30.         sessionMap.put(sid, session);
31.     }
33.     /**
34.      * 收到客户端消息后调用的方法
35.      *
36.      * @param message 客户端发送过来的消息
37.      */
38.     @OnMessage
39.     public void onMessage(String message, @PathParam("sid") String sid) {
40.         System.out.println("收到来自客户端：" + sid + "的信息:" + message);
41.     }
43.     /**
44.      * 连接关闭调用的方法
45.      *
46.      * @param sid
47.      */
48.     @OnClose
49.     public void onClose(@PathParam("sid") String sid) {
50.         System.out.println("连接断开:" + sid);
51.         sessionMap.remove(sid);
52.     }
54.     /**
55.      * 群发
56.      *
57.      * @param message
58.      */
59.     public void sendToAllClient(String message) {
60.         Collection<Session> sessions = sessionMap.values();
61.         for (Session session : sessions) {
62.             try {
63.                 //服务器向客户端发送消息
64.                 session.getBasicRemote().sendText(message);
65.             } catch (Exception e) {
66.                 e.printStackTrace();
67.             }
68.         }
69.     }
71. }

复制代码

来单提醒

用户下单乐成后，需要第一时间通知外卖商家，通知有两种：语音弹幕 弹出提示框
消息分为两种：来单提醒 和 客户催单
在paysuccess后面加

1. //通过websocket向客户端推送数据  type orderId  content
2. Map map=new HashMap<>();
3. map.put("type",1);//1  表示来电提醒  2表示客户催单
4. map.put("orderId",ordersDB.getId());
5. map.put("content","订单号： "+outTradeNo);
6. String json= JSON.toJSONString(map);
7. webSocketServer.sendToAllClient(json);

复制代码

客户催单

Controller层

1. /*
2. \* 客户催单
3. \* */
4. @GetMapping("/reminder/{id}")
5. @ApiOperation("客户催单")
6. public Result reminder(@PathVariable("id") Long id){
7.        orderService.reminder(id);
8.   return Result.success();
9. }

复制代码

service层

1. /*
3. \* 客户催单
5. \* */
6. @Override
7. public void reminder(Long id) {
8.   // 根据id查询订单
9.   Orders ordersDB = orderMapper.getById(id);
10.   // 校验订单是否存在，并且状态为4
11.   if (ordersDB == null) {
12.      throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
13.   }
14.   Map map=new HashMap<>();
15.   map.put("type",2);//1表示来单提醒  2表示客户催单
16.   map.put("orderId",id);
17.   map.put("content","订单号: "+ordersDB.getId());
18.   //调用webSocket向客户端浏览器发送消息
19.   webSocketServer.sendToAllClient(JSON.toJSONString(map));
21. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。