使用webSocket实现及时通信

骑猪看日落 2022-05-29 23:44 549阅读 0赞

本方案是为了解决前后台及时通信设计的,例如后台代码触发一个事件,可以及时的传递给前台,也就是消息的推送功能.
关于消息的推送,方案1是使用定时任务,Cron表达式设置每分钟处理一下后台逻辑进行事件的判断.方案2是使用webSocket建立消息通信通道,挂起一个线程进行时间的判断和消息推送.虽然都能实现消息推送的功能,但是方案二明显效率更高,对服务器造成的压力相对于方案1来说也更小,这里就简单介绍下使用第二种方案进行消息的及时推送实现方法.
首先说下使用webSocket进行访问是路径格式:ws:// path + “wsMy?jspCode=” + jspCode
以WS开头,后面可以追加参数,上文路径是中的wsMy是为了接下来的过滤器过滤,防止恶意访问.
首先添加webSocket依赖:

  1. <!--spring-websocket-->
  2.       <dependency>
  3.           <groupId>org.springframework</groupId>
  4.           <artifactId>spring-websocket</artifactId>
  5.           <version>4.0.1.RELEASE</version>
  6.       </dependency>

接下来就是前台页面上的触发访问webSocket:

  1. function getUserId() { 
  2.     $.ajax({
  3.         type : "post",
  4.         url : "${ctx}/memo/getCurrentUserId",
  5.         beforeSend: function () { 
  6.             //加载中
  7.             waitload();
  8.         },
  9.         success : function(data) { 
  10.             currentUserId = data;
  11.             closewait();
  12.             //动态获取当前系统服务器IP地址
  13.             //若执行成功的话，则隐藏进度条提示
  14.             //${ctx}为定义的项目名称,此处不展示,因地制宜
  15.             var path = addrAndPort+"${ctx}/"
  16.             console.log("当前系统的IP及端口号为:"+path);
  17.             var userId = currentUserId;
  18.             if(userId==-1){
  19.                 window.location.href="${ctx}/memo/testWebSocket";
  20.             }
  21.             var jspCode = userId;
  22.             var websocket;
  23.             if ('WebSocket' in window) {
  24.                 //alert("webSocket"+"ws://" + path + "wsMy?jspCode=" + jspCode);
  25.                 <shiro:hasPermission name="user_add_custommenu">
  26.                 websocket = new WebSocket("ws://" + path + "wsMy?jspCode=" + jspCode);
  27.                 </shiro:hasPermission>
  28.             } else if ('MozWebSocket' in window) {
  29.                 websocket = new MozWebSocket("ws://" + path + "wsMy?jspCode=" + jspCode);
  30.             } else {
  31.                 websocket = new SockJS("http://" + path + "wsMy/sockjs?jspCode=" + jspCode);
  32.             }
  33.             websocket.onopen = function(event) { 
  34.                 console.log("WebSocket:已连接");
  35.                 console.log(event);
  36.             };
  37.             websocket.onmessage = function(event) { 
  40.                 if (event.data =="木有消息啊"){
  41.                     //alert("木有消息啊,测试webSocket是否死亡")
  42.                 }else {
  43.                     alert("您有新的提醒,请进入系统首页进行查看")
  44.                     window.flushParent();
  45.                     var  aaa   = event.data.split("*");
  46.                     var id = aaa[0];
  47.                     var content = aaa[1];
  48.                     window.layer.alert(content, {
  49.                          skin: 'layui-layer-molv' //样式类名 自定义样式
  50.                          ,closeBtn: 1    // 是否显示关闭按钮
  51.                          ,anim: 1 //动画类型
  52.                          ,btn: ['取消提醒','确定'] //按钮
  53.                          ,icon: 6    // icon
  54.                         ,yes:function(){ 
  55.                             $.ajax({
  56.                                 type : "post",
  57.                                 data :{
  58.                                     id :id
  59.                                 },
  60.                                 url : "${ctx}/memo/cancleNotepadByMap",
  61.                                 success : function(data) { 
  62.                                     window.location.reload();
  63.                                     //若执行成功的话，则隐藏进度条提示
  64.                                     if (data != null && data != 'undefined'
  65.                                         && data == 1) {
  66.                                         layer.msg('该提醒取消成功!', {icon: 6,time:1000});
  67.                                         parent.flushParent();
  68.                                         layer_close();
  69.                                         window.location.reload();
  70.                                     }else if (data == -1) {
  71.                                         layer.msg('记事本名称已经存在!', {icon: 5,time:1000});
  72.                                     }else if (data == 0) {
  73.                                         layer.msg('很抱歉！添加失败!', {icon: 5,time:1000});
  74.                                     }else{
  75.                                         layer.msg('系统异常！请与系统管理员联系!', {icon: 5,time:1000});
  76.                                     }
  77.                                 }
  78.                             });
  79.                         }
  80.                         ,btn2:function(){ 
  81.                                  layer.msg('按钮2')
  82.                             }});
  84.                 }
  85.             };
  86.             websocket.onerror = function(event) { 
  87.                 console.log("WebSocket:发生错误 ");
  88.                 console.log(event);
  89.             };
  90.             websocket.onclose = function(event) { 
  91.                 console.log("WebSocket:已关闭");
  92.                 console.log(event);
  93.             }
  94.         }
  95.     })
  96. }

因为本案例中访问的是当前服务器的路径,所以要对当前服务器的IP以及端口号进行获取,然后赋值给webSocket的访问路径:

  1. /*获取当前用户id*/
  2. var addrAndPort = "";
  3. function getAddrAndport() { 
  4.     $.ajax({
  5.         type : "get",
  6.         url : "${ctx}/getAddrAndport",
  7.         beforeSend: function () { 
  8.             //加载中
  9.             waitload();
  10.         },
  11.         success : function(data) { 
  12.             addrAndPort = data;
  13.         }
  14.     })
  15. }
  17. 后台获取IP以及端口号返回到前台:
  18. @RequestMapping(value = "/getAddrAndport", method = { RequestMethod.GET,
  19.             RequestMethod.POST })
  20.     @ResponseBody
  21.     public Object getAddrAndport(HttpServletRequest request,
  22.                                 HttpServletResponse response) {
  23.         String addrAndPort = "";
  24.         addrAndPort = request.getLocalAddr()+":"+request.getLocalPort();
  25.         return addrAndPort;
  26.     }
  27. 之前查找资料,获取当前系统的IP以及端口号的方法,杂乱,还是直接从HttpServletRequest 中直接获取最为直接和准确.

当前台页面触发访问的时候,后台服务器接收到访问请求并且进行处理,这时候我把后台关于webSocket的请求分为三个文件:
1:HandShake.java

  1. package com.yyx.webSocket;
  3. import org.springframework.http.server.ServerHttpRequest;
  4. import org.springframework.http.server.ServerHttpResponse;
  5. import org.springframework.http.server.ServletServerHttpRequest;
  6. import org.springframework.web.socket.WebSocketHandler;
  7. import org.springframework.web.socket.server.HandshakeInterceptor;
  9. import java.util.*;
  10. import java.util.HashMap;
  11. import java.util.Iterator;
  12. import java.util.Map;
  13. import java.util.Map.Entry;
  14. /** * Created by zhangrui on 2018/1/22. */
  15. public class HandShake implements HandshakeInterceptor{ 
  16.     @Override
  17.     public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
  18.         // TODO Auto-generated method stub
  19.         String jspCode = ((ServletServerHttpRequest) request).getServletRequest().getParameter("jspCode");
  20.         // 标记用户
  21.        // String userId = (String) ((ServletServerHttpRequest) request).getServletRequest().getSession().getAttribute("userId");
  22.         if(jspCode!=null){
  23.             attributes.put("jspCode", jspCode);
  24.         }else{
  25.             return false;
  26.         }
  27.         return true;
  28.     }
  30.     @Override
  31.     public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {
  32.         // TODO Auto-generated method stub
  33.     }
  34. }

2.MyWebSocketConfig.java

  1. package com.yyx.webSocket;
  3. import org.springframework.stereotype.Component;
  4. import org.springframework.web.servlet.config.annotation.EnableWebMvc;
  5. import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
  6. import org.springframework.web.socket.config.annotation.EnableWebSocket;
  7. import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
  8. import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;
  10. import javax.annotation.Resource;
  12. /** * Created by zhangrui on 2018/1/22. */
  13. @Component
  14. @EnableWebMvc
  15. @EnableWebSocket
  16. public class MyWebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer { 
  17.     @Resource
  18.     MyWebSocketHandler handler;
  19.     @Override
  20.     public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
  21.         // TODO Auto-generated method stub
  22.         registry.addHandler(handler, "/wsMy");
  23.         registry.addHandler(handler, "/wsMy/sockjs").withSockJS();
  24.     }
  25. }

3:MyWebSockethandler.java访问成功后的处理逻辑,本文中是使用线程写的,因人而异.

  1. package com.yyx.webSocket;
  3. import com.google.gson.GsonBuilder;
  4. import com.yyx.zbhr.controller.MemoController;
  5. import com.yyx.zbhr.entity.MemoEntity;
  6. import com.yyx.zbhr.entity.NotepadEntity;
  7. import com.yyx.zbhr.entity.User;
  8. import com.yyx.zbhr.service.MMemoService;
  9. import com.yyx.zbhr.service.MPersonInfoService;
  10. import com.yyx.zbhr.utils.UserUtil;
  11. import org.apache.commons.collections.map.HashedMap;
  12. import org.apache.shiro.authz.annotation.RequiresAuthentication;
  13. import org.apache.shiro.authz.annotation.RequiresPermissions;
  14. import org.slf4j.Logger;
  15. import org.slf4j.LoggerFactory;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.stereotype.Component;
  18. import org.springframework.web.socket.*;
  20. import javax.servlet.http.HttpSession;
  21. import java.io.IOException;
  22. import java.net.URI;
  23. import java.text.SimpleDateFormat;
  24. import java.util.*;
  25. import java.util.Map.*;
  27. /** * Created by zhangrui on 2018/1/22. */
  28. @Component
  29. public class MyWebSocketHandler implements WebSocketHandler {
  30.     public static final Map<String, WebSocketSession> userSocketSessionMap;
  31.     private  static Logger logger = LoggerFactory.getLogger(MyWebSocketHandler.class);
  32.     private static Calendar fromCal=Calendar.getInstance();
  33.     @Autowired(required = false)
  34.     private MPersonInfoService mPersonInfoService;
  36.     @Autowired(required = false)
  37.     private MMemoService mMemoService;
  38.     static {
  39.         userSocketSessionMap = new HashMap<String, WebSocketSession>();
  40.     }
  41.     public static WebSocketSession session1 ;
  42.     @Override
  43.     public void afterConnectionEstablished(WebSocketSession session) throws Exception {
  44.         // TODO Auto-generated method stub
  45.         //HttpSession httpSession = (HttpSession) session;
  46.         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm");
  47.         //调用接口获取ID
  48.         //Long userId = mMemoService.getCurrentUserId();
  49.         Map<String,Object> map = new HashedMap();
  50.         /*//wsMy?jspCode=23*/
  51.         String uri = session.getUri().toString();
  52.         String[] split = uri.split("=");
  53.         int currentUserId = Integer.parseInt(split[1]);
  54.         // TODO 自动shiro获取id失败
  55.         map.put("userId",currentUserId);
  56.         String jspCode = (String) session.getHandshakeAttributes().get("jspCode");
  57.         if (userSocketSessionMap.get(jspCode) == null) {
  58.             userSocketSessionMap.put(jspCode, session);
  59.         }
  60.             new Thread(new Runnable() {
  61.                 public void run() {
  62.                     while(true){
  63.                         Date date = new Date();
  64.                         String format = simpleDateFormat.format(date);
  65.                         List<NotepadEntity> notepadEntities = mMemoService.selectNotepadForNotice(map);
  66.                         for (int i = 0; i < notepadEntities.size(); i++) { 
  67.                             String format1 = simpleDateFormat.format(notepadEntities.get(i).getStarTime());
  68.                             String format2 = simpleDateFormat.format(notepadEntities.get(i).getEndTime());
  69.                             StringBuffer message = new StringBuffer();
  70.                             int flag1 = date.compareTo(notepadEntities.get(i).getEndTime());
  71.                             int flag2 = date.compareTo(notepadEntities.get(i).getStarTime());
  72.                             if (flag1 < 0 && flag2 >= 0) {
  73.                                 try {
  74.                                     String noteType = "";
  75.                                     if (notepadEntities.get(i).getNoteType() == 1){
  76.                                         noteType = "工作";
  77.                                     }else if (notepadEntities.get(i).getNoteType() == 2){
  78.                                         noteType = "生活";
  79.                                     }else if (notepadEntities.get(i).getNoteType() == 3){
  80.                                         noteType = "家庭";
  81.                                     }else if (notepadEntities.get(i).getNoteType() == 4){
  82.                                         noteType = "私密";
  83.                                     }else {
  84.                                         noteType = "其他";
  85.                                     }
  86.                                     message.append(notepadEntities.get(i).getId()+"*");
  87.                                     message.append("<b>日程类型:</b></br>"+noteType+"</br>");
  88.                                     message.append("<b>起始时间:</b></br>"+format1+"</br>");
  89.                                     message.append("<b>终止时间:</b></br>"+format2+"</br>");
  90.                                     message.append("<b>主题:</b></br>"+notepadEntities.get(i).getTitle()+"</br>");
  91.                                     message.append("<b>内容:</b></br>"+notepadEntities.get(i).getContent()+"</br>");
  92.                                     session.sendMessage(new TextMessage(message,true));
  93.                                     //session.sendMessage(new TextMessage(new GsonBuilder().create().toJson("\"日程类型\":\"" + noteType + "\";\"日程时间\":\"" + simpleDateFormat.format(notepadEntities.get(i).getStarTime())+"--"+simpleDateFormat.format(notepadEntities.get(i).getEndTime()) + "\";\"标题:\":\"" +  notepadEntities.get(i).getTitle() + "\";\"内容:\":\"" + notepadEntities.get(i).getContent() + "\"")));
  94.                                     //session.sendMessage(new TextMessage("日程提醒\n日程事件:"+format1+"--"+format2+"\n"+"标题:"+notepadEntities.get(i).getTitle()+"\n"+"内容:"+notepadEntities.get(i).getContent()+"类型:"+noteType+"\n"+""));
  95.                                 } catch (IOException e) {
  96.                                     e.printStackTrace();
  97.                                 }
  98.                             }else if(flag1>0){
  99.                                 try {
  100.                                     String noteType = "";
  101.                                     if (notepadEntities.get(i).getNoteType() == 1){
  102.                                         noteType = "工作";
  103.                                     }else if (notepadEntities.get(i).getNoteType() == 2){
  104.                                         noteType = "生活";
  105.                                     }else if (notepadEntities.get(i).getNoteType() == 3){
  106.                                         noteType = "家庭";
  107.                                     }else if (notepadEntities.get(i).getNoteType() == 4){
  108.                                         noteType = "私密";
  109.                                     }else {
  110.                                         noteType = "其他";
  111.                                     }
  112.                                     message.append(notepadEntities.get(i).getId()+"*");
  113.                                     message.append("<h3 style=\"color:red\">日程过期提醒</h3>");
  114.                                     message.append("<b>日程类型:</b></br>"+noteType+"</br>");
  115.                                     message.append("<b>起始时间:</b></br>"+format1+"</br>");
  116.                                     message.append("<b>终止时间:</b></br>"+format2+"</br>");
  117.                                     message.append("<b>主题:</b></br>"+notepadEntities.get(i).getTitle()+"</br>");
  118.                                     message.append("<b>内容:</b></br>"+notepadEntities.get(i).getContent()+"</br>");
  119.                                     session.sendMessage(new TextMessage(message,true));
  120.                                     //session.sendMessage(new TextMessage(new GsonBuilder().create().toJson("\"日程类型\":\"" + noteType + "\";\"日程时间\":\"" + simpleDateFormat.format(notepadEntities.get(i).getStarTime())+"--"+simpleDateFormat.format(notepadEntities.get(i).getEndTime()) + "\";\"标题:\":\"" +  notepadEntities.get(i).getTitle() + "\";\"内容:\":\"" + notepadEntities.get(i).getContent() + "\"")));
  121.                                     //session.sendMessage(new TextMessage("日程提醒\n日程事件:"+format1+"--"+format2+"\n"+"标题:"+notepadEntities.get(i).getTitle()+"\n"+"内容:"+notepadEntities.get(i).getContent()+"类型:"+noteType+"\n"+""));
  122.                                 } catch (IOException e) {
  123.                                     e.printStackTrace();
  124.                                 }
  125.                             }else {
  126.                                 String noteType = "";
  127.                                 if (notepadEntities.get(i).getNoteType() == 1){
  128.                                     noteType = "工作";
  129.                                 }else if (notepadEntities.get(i).getNoteType() == 2){
  130.                                     noteType = "生活";
  131.                                 }else if (notepadEntities.get(i).getNoteType() == 3){
  132.                                     noteType = "家庭";
  133.                                 }else if (notepadEntities.get(i).getNoteType() == 4){
  134.                                     noteType = "私密";
  135.                                 }else {
  136.                                     noteType = "其他";
  137.                                 }
  138.                                 //session.sendMessage(new TextMessage(new GsonBuilder().create().toJson("\"日程类型 \":\" " + noteType + "\";\"日程时间\":\"" + simpleDateFormat.format(notepadEntities.get(i).getStarTime())+"--"+simpleDateFormat.format(notepadEntities.get(i).getEndTime()) + "\";\"标题\":\"" +  notepadEntities.get(i).getTitle() + "\";\"内容 \":\"" + notepadEntities.get(i).getContent() + "\"")));
  139.                                 //session.sendMessage(new TextMessage(new GsonBuilder().create().toJson("\"number\":\"" + i + "\";\"deptId\":\"" + format + "\";\"事件:\":\"" + "这只是哥哥拿来测试的事件" + i + "\"")));
  140.                                 /* message.append("<b>日程类型:</b></br>"+noteType+"</br>"); message.append("<b>起始时间:</b></br>"+format1+"</br>"); message.append("<b>终止时间:</b></br>"+format2+"</br>"); message.append("<b>主题:</b></br>"+notepadEntities.get(i).getTitle()+"</br>"); message.append("<b>内容:</b></br>"+notepadEntities.get(i).getContent()+"</br>"); session.sendMessage(new TextMessage(message,true));*/
  141.                                 try {
  142.                                     session.sendMessage(new TextMessage("木有消息啊",true));
  143.                                 } catch (IOException e) {
  144.                                     e.printStackTrace();
  145.                                 }
  146.                             }
  147.                         }
  148.                         try {
  149.                             Thread.sleep(1000*60);
  150.                         } catch (InterruptedException e) {
  151.                             e.printStackTrace();
  152.                         }
  153.                     }
  155.                 }
  156.             }).start();
  157.     }
  159.     @Override
  160.     public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
  161.         // TODO Auto-generated method stub
  162.         //Message msg=new Gson().fromJson(message.getPayload().toString(),Message.class);
  163.         //msg.setDate(new Date());
  164. //      sendMessageToUser(msg.getTo(), new TextMessage(new GsonBuilder().setDateFormat("yyyy-MM-dd HH:mm:ss").create().toJson(msg)));
  166.         session.sendMessage(message);
  167.     }
  169.     @Override
  170.     public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
  171.         // TODO Auto-generated method stub
  172.         if (session.isOpen()) {
  173.             session.close();
  174.         }
  175.         Iterator<Map.Entry<String, WebSocketSession>> it = userSocketSessionMap
  176.                 .entrySet().iterator();
  177.         // 移除Socket会话
  178.         while (it.hasNext()) {
  179.             Map.Entry<String, WebSocketSession> entry = it.next();
  180.             if (entry.getValue().getId().equals(session.getId())) {
  181.                 userSocketSessionMap.remove(entry.getKey());
  182.                 System.out.println("Socket会话已经移除:用户ID" + entry.getKey());
  183.                 break;
  184.             }
  185.         }
  186.     }
  188.     @Override
  189.     public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
  190.         // TODO Auto-generated method stub
  191.         System.out.println("Websocket:" + session.getId() + "已经关闭");
  192.         Iterator<Entry<String, WebSocketSession>> it = userSocketSessionMap
  193.                 .entrySet().iterator();
  194.         // 移除Socket会话
  195.         while (it.hasNext()) {
  196.             Entry<String, WebSocketSession> entry = it.next();
  197.             if (entry.getValue().getId().equals(session.getId())) {
  198.                 userSocketSessionMap.remove(entry.getKey());
  199.                 //TODO 对webSocket资源进行回收
  200.                 System.gc();
  201.                 System.out.println("Socket会话已经移除:用户ID" + entry.getKey());
  202.                 break;
  203.             }
  204.         }
  205.     }
  207.     @Override
  208.     public boolean supportsPartialMessages() {
  209.         return false;
  210.     }
  211.     public void broadcast(final TextMessage message) throws IOException {
  212.         Iterator<Entry<String, WebSocketSession>> it = userSocketSessionMap
  213.                 .entrySet().iterator();
  215.         // 多线程群发
  216.         while (it.hasNext()) {
  218.             final Entry<String, WebSocketSession> entry = it.next();
  220.             if (entry.getValue().isOpen()) {
  221.                 new Thread(new Runnable() {
  223.                     public void run() {
  224.                         try {
  225.                             if (entry.getValue().isOpen()) {
  226.                                 entry.getValue().sendMessage(message);
  227.                             }
  228.                         } catch (IOException e) {
  229.                             e.printStackTrace();
  230.                         }
  231.                     }
  233.                 }).start();
  234.             }
  236.         }
  237.     }
  238.     public void sendMessageToJsp(final TextMessage message,String type) throws IOException {
  239.         Iterator<Entry<String, WebSocketSession>> it = userSocketSessionMap
  240.                 .entrySet().iterator();
  242.         // 多线程群发
  243.         while (it.hasNext()) {
  245.             final Entry<String, WebSocketSession> entry = it.next();
  246.             if (entry.getValue().isOpen() && entry.getKey().contains(type)) {
  247.                 new Thread(new Runnable() {
  249.                     public void run() {
  250.                         try {
  251.                             if (entry.getValue().isOpen()) {
  252.                                 entry.getValue().sendMessage(message);
  253.                             }
  254.                         } catch (IOException e) {
  255.                             e.printStackTrace();
  256.                         }
  257.                     }
  259.                 }).start();
  260.             }
  262.         }
  263.     }
  265. }

第三个文件是核心,具体的代码是实验代码,有一部分是冗余代码,粘贴出来仅供参考,值得一提的是,在webSocket进行sendMessage的时候,可选的message格式有多种,当时博主想传回类json,但是传到前台发现处理比较麻烦,所以就传回了StringBuffer类型的,至于StringBuffer和StringBuidder之间的选择,看情况决定,这里不多言.再展示下消息传递后的效果图:
这里写图片描述

对返回到前台的消息处理使用的layer进行弹出,比较好用,样式多.可以直接从layer官网查询样式进行使用,网址….百度.
最后一点,本文中使用的web容器及版本是Tomcat8.0.48,虽然有人说在Tomcat8.0之前,不支持webSocket消息通讯,说的是那时候webSocket协议未制定,但是….博主试了下使用Tomcat7.9可行,所以这里就不再多说废话啦,博主也只是个门外汉,更多更细的webSocket知识点还是留待大家自行发掘吧!
最后一点,请不要诟病博主的访问路径:getAddrAndport,虽然不规范,但是….这破习惯一下子难改啊…逐步改正.
完.

发表评论

表情：
评论列表 （有 0 条评论，549人围观）

还没有评论，来说两句吧...

相关阅读

    相关 使用webSocket实现及时通信

    本方案是为了解决前后台及时通信设计的,例如后台代码触发一个事件,可以及时的传递给前台,也就是消息的推送功能. 关于消息的推送,方案1是使用定时任务,Cron表达式设置每分钟

    骑猪看日落骑猪看日落/ 0 赞/ 550 阅读