欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

SpringBoot+LayIM+t-io 實現(xiàn)好友申請通知流程

 更新時間:2017年12月11日 09:28:31   作者:丶Pz  
這篇文章主要介紹了 SpringBoot+LayIM+t-io 實現(xiàn)好友申請通知流程,本文圖文并茂給大家介紹的非常詳細,需要的朋友可以參考下

前言

在上一篇 Spring boot + LayIM + t-io 文件上傳、 監(jiān)聽用戶狀態(tài)的實現(xiàn) 中,已經(jīng)介紹了兩個小細節(jié):用戶的在離線狀態(tài)和群人數(shù)的狀態(tài)變化。今天的主要內(nèi)容就是用戶加好友的實現(xiàn)。

簡介

加好友,大家用過QQ都知道,無非是發(fā)起好友申請,對方收到消息通知,然后處理。不過,本篇只講前半部分,消息通知的處理留到下一篇去講。因為內(nèi)容有點多,怕是一時半會消化不了。在介紹主體流程之前,先給大家介紹一下準備工作。

準備工作

首先,為了讓數(shù)據(jù)更貼近實戰(zhàn),所以我用了比較“真實”的用戶數(shù)據(jù)。結合fly模板,完善了用戶中心頭部的用戶信息的數(shù)據(jù)綁定。數(shù)據(jù)綁定部分判斷了是否已經(jīng)是好友,來決定是否出現(xiàn)“加為好友”的按鈕。示例如下,當用戶自己看到自己的主頁時,是這樣的:

 

看到非好友的用戶主頁,是這樣的:

 

綁定數(shù)據(jù)部分,簡單給大家介紹一下,就是用thymleaf模板綁定。后臺訪問頁面的時候,將 Model 賦值即可。

/**
 * 屬性賦值
 * */
 private void setModel(User user,Model model){
 long currentUserId = getUserId();
 long visitUserId = user.getId();
 //是否是自己
 boolean isSelf = currentUserId == visitUserId;
 //兩個用戶是否已經(jīng)是好友
 boolean isFriend = groupService.isFriend(currentUserId,visitUserId);
 Map<String,Object> userMap = new HashMap<>(8);
 userMap.put("avatar",user.getAvatar());
 userMap.put("name",user.getUserName());
 userMap.put("addtime", TimeUtil.formatDate(user.getCreateAt())+" 加入");
 if(user.getSign()==null ||user.getSign().length()==0) {
  userMap.put("sign", "");
 }else {
  userMap.put("sign", "(" + user.getSign() + ")");
 }
 userMap.put("uid",user.getId());
 userMap.put("self",isSelf || isFriend);
 model.addAttribute("user",userMap);
 }

然后頁面上,將model中的數(shù)據(jù)取出來。

<div class="fly-home" style="background-image: url();">
 <input type="hidden" th:value="${user.uid}" id="visitUid"/>
 <img src="" th:src="${user.avatar}" th:alt="${user.name}"/>
 <h1>
  <p th:text="${user.name}"></p>
  <i class="iconfont icon-nan"></i>
 </h1>
 <p class="fly-home-info">
  <!--<i class="iconfont icon-zuichun" title="飛吻"></i><span style="color: #FF7200;">67206飛吻</span>-->
  <i class="iconfont icon-shijian"></i><span th:text="${user.addtime}"></span>
  <!--<i class="iconfont icon-chengshi"></i><span>來自杭州</span>-->
  <i class="iconfont icon-qq" th:if="${user.self==false}"></i><a lay-event="addFriend" href="#" rel="external nofollow" title="添加TA為好友" th:if="${user.self==false}">加為好友</a>
 </p>
 <p class="fly-home-sign" th:text="${user.sign}"></p>
 </div>

ok,以上就是簡單的準備工作。想了解詳情代碼的可以去文末的github地址去搜尋。

發(fā)起好友申請

我們先根據(jù)layim的業(yè)務分析。首先,要知道我們要加誰(toId)為好友。然后在加上一個備注(remark)。這些東西交給后臺就OK了。為了避免連表查詢,對于系統(tǒng)消息的存儲我做了用戶名和用戶頭像的冗余。表主要包含字段:用戶ID,用戶頭像,用戶名,被申請用戶ID,申請時間,申請類型,備注,已讀等其他屬性。

所以,發(fā)起好友申請就很簡單了。就是一個添加功能,前端傳的就是被申請人用戶ID和申請備注,后端組織數(shù)據(jù)插入到數(shù)據(jù)庫,代碼如下:

/**
 * 提交好友申請
 * */
 public JsonResult saveFriendApply(long toId,String remark){
 remark = HtmlUtils.htmlEscape(remark);
 ContextUser user = ShiroUtil.getCurrentUser();
 long userId = Long.parseLong(user.getUserid());
 int record = applyRepository.countByToidAndUidAndTypeAndResult(toId,userId,ApplyType.friend,0);
 if(record > 0){
  return JsonResult.fail("已經(jīng)申請過");
 }
 Apply apply = new Apply();
 apply.setType(ApplyType.friend);
 apply.setToid(toId);
 apply.setRemark(remark);
 apply.setUid(userId);
 apply.setAvatar(user.getAvatar());
 apply.setName(user.getUsername());
 apply.setRead(false);
 apply.setResult(0);
 return saveApply(apply);
 }

OK,申請完了,下面我們要做啥?沒錯,通知對方,喂,我向你發(fā)送了申請,快快處理。在這里呢我遇到了一個問題。由于springboot程序占用端口 8080,而t-io占用端口8888,也就是說,如果我想在8080端口的業(yè)務中主動調用8888的服務推送,我不知道如何獲取相應的channelContext。不過經(jīng)過詢問作者之后,一句話解決了我的問題。

拿到 ServerGroupContext ,問題迎刃而解。

在之前的程序啟動的時候注冊了 LayimWebsocketStarter 這個bean。所以,在8080業(yè)務端如果能拿到它的話就沒問題了。

得到 LayimWebsocketStarter ,就能得到  ServerGroupContext, 然后就能在服務端做主動推送了。

當然可能沒有開發(fā)過這個東西,對于上文中的問題不是很理解,沒關系,其實我就想說明,如果從服務端主動向客戶端推送消息的話,使用ServerGroupContext即可。

服務端主動推送

以下代碼在  com.fyp.layim.im.common.util.PushUtil 中

OK,接上文,我們按照步驟來。

第一步,獲取 LayimWebsocketStarter 。

/**
 * 獲取starter
*/
private static LayimWebsocketStarter getStarter(){
 return (LayimWebsocketStarter)SpringUtil.getBean("layimWebsocketStarter");
 }

第二步,獲取 ServerGroupContext

private static ServerGroupContext getServerGroupContext(){
 return getStarter().getServerGroupContext();
 }

第三步,獲取 ChannelContext。

/**
 * 獲取channelContext
 * */
 private static ChannelContext getChannelContext(String toId) {
 ServerGroupContext context = getServerGroupContext();
 //找到用戶
 ChannelContext channelContext = context.users.find(context, toId);
 return channelContext;
 }

第四步,發(fā)射,這里的代碼就和聊天中的那部分代碼差不多了。核心部分就是,獲取ChannelContext,然后給他發(fā)送消息。如果不在線就不用管。

/**
 * 服務端主動推送消息
 * */
 public static void pushApplyMessage(String toId) {
 logger.info("執(zhí)行到了發(fā)送方法:pushApplyMessage");
 LayimToClientNoticeMsgBody body = new LayimToClientNoticeMsgBody();
 ChannelContext channelContext = getChannelContext(toId);
 //先判斷是否在線,再去查詢數(shù)據(jù)庫,減少查詢次數(shù)
 if (channelContext != null && !channelContext.isClosed()) {
  int count = getApplyService().getUnreadMsgCount(Long.parseLong(toId));
  body.setCount(count);
  push(channelContext, body);
 }
 } 
/**
 * 服務端主動推送消息
 * */
 private static void push(ChannelContext channelContext,Object msg) {
 try {
  WsResponse response = BodyConvert.getInstance().convertToTextResponse(msg);
  Aio.send(channelContext, response);
 }catch (IOException ex){
 }
 }

現(xiàn)在推送已經(jīng)搞定了,那么什么時候推送呢?由于這個系統(tǒng)消息的推送可以不用那么即時,于是我看了下,springboot里面有類似的事件機制,于是乎 ApplyEvent 就誕生了。

public class ApplyEvent extends ApplicationEvent {
 public ApplyEvent(Object source) {
 super(source);
 }
 private long toid;
 public long getToId(){
 return toid;
 }
 public ApplyEvent(Object source, long toId) {
 super(source);
 this.toid = toId;
 }
}

在創(chuàng)建一個Listener,監(jiān)聽事件。

public class ApplyListener implements ApplicationListener<ApplyEvent> {
 private Logger logger = LoggerFactory.getLogger(ApplyListener.class);
 @Override
 public void onApplicationEvent(ApplyEvent applyEvent) {
 new Thread(){
  public void run(){
  Long toId = applyEvent.getToId();
  //這里就要調用上文中的推送了
  PushUtil.pushApplyMessage(toId.toString());
  }
 }.start();
 }
}

不過我有個疑問,發(fā)現(xiàn)listener中執(zhí)行的時候是同步的。后來加了@Async 和@EnableAsync 也沒用,于是我就用了new Thread().start()實現(xiàn)異步,確保不影響主要申請流程。(這是個疑問,自己沒搞明白的地方)

最后,別忘了在Application啟動的時候把listener加上。

public static void main(String[] args) {
 SpringApplication springApplication = new SpringApplication(LayimApplication.class);
 /**
  * 這里監(jiān)聽增加listener,listener才會觸發(fā)
  * ApplyListener 是監(jiān)聽好友申請的事件
  * */
 springApplication.addListeners(new ApplyListener());
 springApplication.run(args);
 }

功能拼接

馬上就要成功了,我們在把事件串起來,在好友申請成功之后,發(fā)布事件。

/**
 * 好友申請
 * */
 @PostMapping(value = "/apply-friend")
 public JsonResult apply(@RequestParam("toid") Long toId,@RequestParam("remark") String remark){
 JsonResult result = applyService.saveFriendApply(toId, remark);
 //申請成功,發(fā)布申請事件,通知 toId處理消息,如果不在線,不會進行處理
 if(result.isSuccess()){
  applicationContext.publishEvent(new ApplyEvent("apply",toId));
 }
 return result;
 }

功能演示

講了那么多,給大家看一下成品效果。(用戶場景:安小鳥加皇上為好友,皇上接收消息并查看)

 

皇上收到消息,系統(tǒng)彈出左下角的小數(shù)字4。(調用 layim.msgbox(msgCount) 方法)

 

皇上點開消息盒子:

 

皇上收到了四位愛妃的申請,寢食難安,他會怎么處理呢?欲知后事如何,且聽下回分解~~~

總結

本篇主要介紹了一個加好友的流程的實現(xiàn)。

  1. 好友申請按鈕出不出現(xiàn)取決于用戶是否為自己,是否已經(jīng)是好友。(后端也要做驗證)
  2. t-io的服務端主動推送,如何調用。關鍵詞: ServerGroupContext
  3. event的使用,除了applicationEvent,還可以拓展其他類型,如消息隊列,eventbus等。
  4. 各種細節(jié)處理,比如先判斷對方是否在線,在去查詢數(shù)據(jù)庫?;蛘呓Y合緩存等
  5. 由于是自己摸索,難免有代碼繁雜混亂之處,

文中代碼地址: https://github.com/fanpan26/SpringBootLayIM

                           http://xiazai.jb51.net/201712/yuanma/SpringBootLayIM-master.rar

以上所述是小編給大家介紹的SpringBoot+LayIM+t-io 實現(xiàn)好友申請通知流程,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!

相關文章

  • Spring?Boot?實現(xiàn)Redis分布式鎖原理

    Spring?Boot?實現(xiàn)Redis分布式鎖原理

    這篇文章主要介紹了Spring?Boot實現(xiàn)Redis分布式鎖原理,文章圍繞主題展開詳細的內(nèi)容介紹,具有一定的參考價值,需要的朋友可以參考一下
    2022-08-08
  • java字符串壓縮解壓示例

    java字符串壓縮解壓示例

    這篇文章主要介紹了java字符串壓縮解壓示例,先壓縮,再加密,再壓縮,數(shù)據(jù)越大,壓縮比例越高,需要的朋友可以參考下
    2014-03-03
  • 詳解Spring整合Quartz實現(xiàn)動態(tài)定時任務

    詳解Spring整合Quartz實現(xiàn)動態(tài)定時任務

    本篇文章主要介紹了詳解Spring整合Quartz實現(xiàn)動態(tài)定時任務,具有一定的參考價值,感興趣的小伙伴們可以參考一下。
    2017-03-03
  • Java8時間api之LocalDate/LocalDateTime的用法詳解

    Java8時間api之LocalDate/LocalDateTime的用法詳解

    在項目中,時間的使用必不可少,而java8之前的時間api?Date和Calander等在使用上存在著很多問題,于是,jdk1.8引進了新的時間api-LocalDateTime,本文就來講講它的具體使用吧
    2023-05-05
  • Spring整合MyBatis圖示過程解析

    Spring整合MyBatis圖示過程解析

    這篇文章主要介紹了Spring整合MyBatis圖示過程解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-11-11
  • Spark?實現(xiàn)自定義加密的示例代碼

    Spark?實現(xiàn)自定義加密的示例代碼

    這篇文章主要介紹了Spark?實現(xiàn)自定義加密的示例代碼,代碼簡單易懂,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧
    2024-07-07
  • JAVA MyBatis入門學習過程記錄

    JAVA MyBatis入門學習過程記錄

    MyBatis是一個支持普通SQL查詢,存儲過程和高級映射的優(yōu)秀持久層框架。這篇文章主要介紹了mybatis框架入門學習教程,需要的朋友可以參考下,希望能幫助到你
    2021-06-06
  • Spring中Controller和RestController的區(qū)別詳解

    Spring中Controller和RestController的區(qū)別詳解

    這篇文章主要介紹了Spring中Controller和RestController的區(qū)別詳解,@Controller是標識一個Spring類是Spring MVC controller處理器,@Controller類中的方法可以直接通過返回String跳轉到jsp、ftl、html等模版頁面,需要的朋友可以參考下
    2023-09-09
  • SpringBoot+Vue前后端分離實現(xiàn)審核功能的示例

    SpringBoot+Vue前后端分離實現(xiàn)審核功能的示例

    在實際開發(fā)中,審核功能是一個非常常用的功能,本文就來介紹一下使用SpringBoot+Vue前后端分離實現(xiàn)審核功能的示例,具有一定的參考價值,感興趣的可以了解一下
    2024-02-02
  • Java 8中日期和時間的處理方法

    Java 8中日期和時間的處理方法

    Java 8新增了LocalDate和LocalTime接口,接下來通過本文給大家介紹Java 8中日期和時間的處理方法,非常不錯,感興趣的朋友一起看下吧
    2016-08-08

最新評論