devbox
花生_TL007
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

JAVA集成腾讯云即时通讯IM服务端_java如何整合 腾讯im

作者：花生_TL007 | 2024-03-02 02:41:49

赞

踩

java如何整合 腾讯im

一. 腾讯IM快速入门
1. 注册腾讯云账号，找到即时通信IM控制台
腾讯IM控制台：登录 - 腾讯云

2. 创建即时通信应用

watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA6JCM5pif5Lq6,size_20,color_FFFFFF,t_70,g_se,x_16
3. 进到应用里面可以看到这个应用的SDKAppID和key(密钥)

 watermark,type_ZHJvaWRzYW5zZmFsbGJhY2s,shadow_50,text_Q1NETiBA6JCM5pif5Lq6,size_20,color_FFFFFF,t_70,g_se,x_16


4. 可以参考官方提供的“服务端API接口文档”和“接口调试工具”
API接口文档：https://cloud.tencent.com/document/product/269
接口在线调试工具：https://tcc.tencentcs.com/im-api-tool/index.html
二. 基于Java对一些方法的简单封装
注：封装的方法覆盖得肯定不全面，可以根据自身需求在此基础上补充

1. 配置文件
#腾讯im相关配置

  1. silence.tencent.cloud.im.sdkAppId=应用SDKAppId
  2. silence.tencent.cloud.im.key=应用Key


2. 腾讯im相关API接口常量类TencentCloudImApiConstant.java

  1. public class TencentCloudImApiConstant {
  2.     /**
  3.      * 账号管理
  4.      */
  5.     public static class AccountManage {
  6.         /**导入单个帐号*/
  7.         public static final String ACCOUNT_IMPORT = "v4/im_open_login_svc/account_import";
  8.         /**导入多个帐号*/
  9.         public static final String MULTI_ACCOUNT_IMPORT = "v4/im_open_login_svc/account_import";
  10.         /**删除帐号*/
  11.         public static final String ACCOUNT_DELETE = "v4/im_open_login_svc/account_delete";
  12.         /**查询帐号*/
  13.         public static final String ACCOUNT_CHECK = "v4/im_open_login_svc/account_check";
  14.         /**失效帐号登录状态*/
  15.         public static final String ACCOUNT_KICK = "v4/im_open_login_svc/kick";
  16.         /**查询账号在线状态*/
  17.         public static final String ACCOUNT_QUERY_STATE = "v4/openim/querystate";
  18.     }
  19.  
  20.     /**
  21.      * 单聊消息
  22.      */
  23.     public static class SingleChatManage {
  24.         /**单发单聊消息*/
  25.         public static final String SEND_MSG = "v4/openim/sendmsg";
  26.         /**批量发单聊消息*/
  27.         public static final String BATCH_SEND_MSG = "v4/openim/batchsendmsg";
  28.         /**导入单聊消息*/
  29.         public static final String IMPORT_MSG = "v4/openim/importmsg";
  30.         /**查询单聊消息*/
  31.         public static final String ADMIN_GET_ROAM_MSG = "v4/openim/admin_getroammsg";
  32.         /**撤回单聊消息*/
  33.         public static final String ADMIN_MSG_WITH_DRAW = "v4/openim/admin_msgwithdraw";
  34.         /**设置单聊消息已读*/
  35.         public static final String ADMIN_SET_MSG_READ = "v4/openim/admin_set_msg_read";
  36.     }
  37.  
  38.     /**
  39.      * 全员推送
  40.      */
  41.     public static class AllPushManage {
  42.         /**全员推送*/
  43.         public static final String IM_PUSH = "v4/all_member_push/im_push";
  44.         /**设置应用属性名称*/
  45.         public static final String IM_SET_ATTR_NAME = "v4/all_member_push/im_set_attr_name";
  46.         /**获取应用属性名称*/
  47.         public static final String IM_GET_ATTR_NAME = "v4/all_member_push/im_get_attr_name";
  48.         /**获取用户属性*/
  49.         public static final String IM_GET_ATTR = "v4/all_member_push/im_get_attr";
  50.         /**设置用户属性*/
  51.         public static final String IM_SET_ATTR = "v4/all_member_push/im_set_attr";
  52.         /**删除用户属性*/
  53.         public static final String IM_REMOVE_ATTR = "v4/all_member_push/im_remove_attr";
  54.         /**获取用户标签*/
  55.         public static final String IM_GET_TAG = "v4/all_member_push/im_get_tag";
  56.         /**添加用户标签*/
  57.         public static final String IM_ADD_TAG = "v4/all_member_push/im_add_tag";
  58.         /**删除用户标签*/
  59.         public static final String IM_REMOVE_TAG = "v4/all_member_push/im_remove_tag";
  60.         /**删除用户所有标签*/
  61.         public static final String IM_REMOVE_ALL_TAGS = "v4/all_member_push/im_remove_all_tags";
  62.     }
  63.  
  64.     /**
  65.      * 资料管理
  66.      */
  67.     public static class PortraitManage {
  68.         /**设置资料*/
  69.         public static final String PORTRAIT_SET = "v4/profile/portrait_set";
  70.         /**拉取资料*/
  71.         public static final String PORTRAIT_GET = "v4/profile/portrait_get";
  72.     }
  73.  
  74.     /**
  75.      * 关系链管理
  76.      */
  77.     public static class RelationManage {
  78.         /**添加好友*/
  79.         public static final String FRIEND_ADD = "v4/sns/friend_add";
  80.         /**导入好友*/
  81.         public static final String FRIEND_IMPORT = "v4/sns/friend_import";
  82.         /**更新好友*/
  83.         public static final String FRIEND_UPDATE = "v4/sns/friend_update";
  84.         /**删除好友*/
  85.         public static final String FRIEND_DELETE = "v4/sns/friend_delete";
  86.         /**删除所有好友*/
  87.         public static final String FRIEND_DELETE_ALL = "v4/sns/friend_delete_all";
  88.         /**校验好友*/
  89.         public static final String FRIEND_CHECK = "v4/sns/friend_check";
  90.         /**拉取好友*/
  91.         public static final String FRIEND_GET = "v4/sns/friend_get";
  92.         /**拉取指定好友*/
  93.         public static final String FRIEND_GET_LIST = "v4/sns/friend_get_list";
  94.         /**添加黑名单*/
  95.         public static final String BLACK_LIST_ADD = "v4/sns/black_list_add";
  96.         /**删除黑名单*/
  97.         public static final String BLACK_LIST_DELETE = "v4/sns/black_list_delete";
  98.         /**拉取黑名单*/
  99.         public static final String BLACK_LIST_GET = "v4/sns/black_list_get";
  100.         /**校验黑名单*/
  101.         public static final String BLACK_LIST_CHECK = "v4/sns/black_list_check";
  102.         /**添加分组*/
  103.         public static final String GROUP_ADD = "v4/sns/group_add";
  104.         /**删除分组*/
  105.         public static final String GROUP_DELETE = "v4/sns/group_delete";
  106.         /**拉取分组*/
  107.         public static final String GROUP_GET = "v4/sns/group_get";
  108.     }
  109.  
  110.     /**
  111.      * 群组管理
  112.      */
  113.     public static class GroupManage {
  114.         /**创建群组*/
  115.         public static final String CREATE_GROUP = "v4/group_open_http_svc/create_group";
  116.         /**获取群详细资料*/
  117.         public static final String GET_GROUP_INFO = "v4/group_open_http_svc/get_group_info";
  118.         /**获取群成员详细资料*/
  119.         public static final String GET_GROUP_MEMBER_INFO = "v4/group_open_http_svc/get_group_member_info";
  120.         /**修改群基础资料*/
  121.         public static final String MODIFY_GROUP_BASE_INFO = "v4/group_open_http_svc/modify_group_base_info";
  122.         /**增加群成员*/
  123.         public static final String ADD_GROUP_MEMBER = "v4/group_open_http_svc/add_group_member";
  124.         /**删除群成员*/
  125.         public static final String DELETE_GROUP_MEMBER = "v4/group_open_http_svc/delete_group_member";
  126.         /**修改群成员资料*/
  127.         public static final String MODIFY_GROUP_MEMBER_INFO = "v4/group_open_http_svc/modify_group_member_info";
  128.         /**解散群组*/
  129.         public static final String DESTROY_GROUP = "v4/group_open_http_svc/destroy_group";
  130.         /**获取用户所加入的群组*/
  131.         public static final String GET_JOINED_GROUP_LIST = "v4/group_open_http_svc/get_joined_group_list";
  132.         /**查询用户在群组中的身份*/
  133.         public static final String GET_ROLE_IN_GROUP = "v4/group_open_http_svc/get_role_in_group";
  134.         /**批量禁言和取消禁言*/
  135.         public static final String FORBID_SEND_MSG = "v4/group_open_http_svc/forbid_send_msg";
  136.         /**获取被禁言群成员列表*/
  137.         public static final String GET_GROUP_SHUT_UIN = "v4/group_open_http_svc/get_group_shutted_uin";
  138.         /**在群组中发送普通消息*/
  139.         public static final String SEND_GROUP_MSG = "v4/group_open_http_svc/send_group_msg";
  140.         /**在群组中发送系统通知*/
  141.         public static final String SEND_GROUP_SYSTEM_NOTIFICATION = "v4/group_open_http_svc/send_group_system_notification";
  142.         /**撤回群消息*/
  143.         public static final String GROUP_MSG_RECALL = "v4/group_open_http_svc/group_msg_recall";
  144.         /**转让群主*/
  145.         public static final String CHANGE_GROUP_OWNER = "v4/group_open_http_svc/change_group_owner";
  146.         /**导入群基础资料*/
  147.         public static final String IMPORT_GROUP = "v4/group_open_http_svc/import_group";
  148.         /**导入群消息*/
  149.         public static final String IMPORT_GROUP_MSG = "v4/group_open_http_svc/import_group_msg";
  150.         /**导入群成员*/
  151.         public static final String IMPORT_GROUP_MEMBER = "v4/group_open_http_svc/import_group_member";
  152.         /**设置成员未读消息计数*/
  153.         public static final String SET_UNREAD_MSG_NUM = "v4/group_open_http_svc/set_unread_msg_num";
  154.         /**删除指定用户发送的消息*/
  155.         public static final String DELETE_GROUP_MSG_BY_SENDER = "v4/group_open_http_svc/delete_group_msg_by_sender";
  156.         /**拉取群历史消息*/
  157.         public static final String GROUP_MSG_GET_SIMPLE = "v4/group_open_http_svc/group_msg_get_simple";
  158.         /**获取直播群在线人数*/
  159.         public static final String GET_ONLINE_MEMBER_NUM = "v4/group_open_http_svc/get_online_member_num";
  160.     }
  161.  
  162.     /**
  163.      * 全局禁言管理
  164.      */
  165.     public static class AllSinentManage {
  166.         /**设置全局禁言*/
  167.         public static final String SET_NO_SPEAKING = "v4/openconfigsvr/setnospeaking";
  168.         /**查询全局禁言*/
  169.         public static final String GET_NO_SPEAKING = "v4/openconfigsvr/getnospeaking";
  170.     }
  171.  
  172.     /**
  173.      * 运营管理
  174.      */
  175.     public static class OperationManage {
  176.         /**拉取运营数据*/
  177.         public static final String GET_APP_INFO = "v4/openconfigsvr/getappinfo";
  178.         /**下载消息记录*/
  179.         public static final String GET_HISTORY = "v4/open_msg_svc/get_history";
  180.         /**获取服务器 IP 地址*/
  181.         public static final String GET_IP_LIST = "v4/ConfigSvc/GetIPList";
  182.     }
  183. }


3. 腾讯im相关常量类TencentCloudImConstant.java

  1. public class TencentCloudImConstant {
  2.     /**
  3.      * IM请求处理结果
  4.      */
  5.     public final static String ACTION_STATUS_OK = "OK";
  6.     public final static String ACTION_STATUS_FAIL = "FAIL";
  7.  
  8.     /**
  9.      * IM发消息是否同步到发送方（1-同步，2-不同步）
  10.      */
  11.     public final static Integer SYNC_OTHER_MACHINE_YES = 1;
  12.     public final static Integer SYNC_OTHER_MACHINE_NO = 2;
  13.  
  14.     /**
  15.      * IM消息对象类型：
  16.      * TIMTextElem    文本消息。
  17.      * TIMLocationElem    地理位置消息。
  18.      * TIMFaceElem    表情消息。
  19.      * TIMCustomElem    自定义消息，当接收方为 iOS 系统且应用处在后台时，此消息类型可携带除文本以外的字段到 APNs。一条组合消息中只能包含一个 TIMCustomElem 自定义消息元素。
  20.      * TIMSoundElem    语音消息。
  21.      * TIMImageElem    图像消息。
  22.      * TIMFileElem    文件消息。
  23.      * TIMVideoFileElem    视频消息。
  24.      */
  25.     public final static String TIM_TEXT_ELEM = "TIMTextElem";
  26.     public final static String TIM_LOCATION_ELEM = "TIMLocationElem";
  27.     public final static String TIM_FACE_ELEM = "TIMFaceElem";
  28.     public final static String TIM_CUSTOM_ELEM = "TIMCustomElem";
  29.     public final static String TIM_SOUND_ELEM = "TIMSoundElem";
  30.     public final static String TIM_IMAGE_ELEM = "TIMImageElem";
  31.     public final static String TIM_FILE_ELEM = "TIMFileElem";
  32.     public final static String TIM_VIDEOFILE_ELEM = "TIMVideoFileElem";
  33.  
  34.     /**
  35.      * 微信响应消息类型
  36.      * WX_MSG_TYPE_EVENT：事件类型，事件类型对应"user_enter_tempsession"表示建立会话
  37.      * WX_MSG_TYPE_TEXT：文本类型
  38.      * WX_MSG_TYPE_TEXT：图片类型
  39.      * WX_MSG_TYPE_TEXT：小程序卡片
  40.      */
  41.     public final static String WX_MSG_TYPE_EVENT = "event";
  42.     public final static String WX_MSG_TYPE_TEXT = "text";
  43.     public final static String WX_MSG_TYPE_IMAGE = "image";
  44.     public final static String WX_MSG_TYPE_APPLET_CARD = "miniprogrampage";
  45. }


4. 发送http请求工具类HttpUtil.java

  1. import com.alibaba.fastjson.JSONObject;
  2. import org.apache.http.Consts;
  3. import org.apache.http.HttpEntity;
  4. import org.apache.http.HttpResponse;
  5. import org.apache.http.NameValuePair;
  6. import org.apache.http.client.HttpClient;
  7. import org.apache.http.client.entity.UrlEncodedFormEntity;
  8. import org.apache.http.client.methods.CloseableHttpResponse;
  9. import org.apache.http.client.methods.HttpGet;
  10. import org.apache.http.client.methods.HttpPost;
  11. import org.apache.http.entity.StringEntity;
  12. import org.apache.http.impl.client.CloseableHttpClient;
  13. import org.apache.http.impl.client.DefaultHttpClient;
  14. import org.apache.http.impl.client.HttpClients;
  15. import org.apache.http.message.BasicNameValuePair;
  16. import org.apache.http.util.EntityUtils;
  17.  
  18. import java.io.IOException;
  19. import java.util.ArrayList;
  20. import java.util.List;
  21. import java.util.Map;
  22.  
  23. public class HttpUtil {
  24.     private static final CloseableHttpClient httpclient = HttpClients.createDefault();
  25.  
  26.     /**
  27.      * 发送HttpGet请求
  28.      * @param url
  29.      * @return
  30.      */
  31.     public static String sendGet(String url) {
  32.  
  33.         HttpGet httpget = new HttpGet(url);
  34.         CloseableHttpResponse response = null;
  35.         try {
  36.             response = httpclient.execute(httpget);
  37.         } catch (IOException e1) {
  38.             e1.printStackTrace();
  39.         }
  40.         String result = null;
  41.         try {
  42.             HttpEntity entity = response.getEntity();
  43.             if (entity != null) {
  44.                 result = EntityUtils.toString(entity);
  45.             }
  46.         } catch (Exception e) {
  47.             e.printStackTrace();
  48.         } finally {
  49.             try {
  50.                 response.close();
  51.             } catch (IOException e) {
  52.                 e.printStackTrace();
  53.             }
  54.         }
  55.         return result;
  56.     }
  57.  
  58.     /**
  59.      * 发送HttpPost请求，参数为map
  60.      * @param url
  61.      * @param map
  62.      * @return
  63.      */
  64.     public static String sendPost(String url, Map<String, String> map) {
  65.         List<NameValuePair> formparams = new ArrayList<NameValuePair>();
  66.         for (Map.Entry<String, String> entry : map.entrySet()) {
  67.             formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
  68.         }
  69.         UrlEncodedFormEntity entity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
  70.         HttpPost httppost = new HttpPost(url);
  71.         httppost.setEntity(entity);
  72.         CloseableHttpResponse response = null;
  73.         try {
  74.             response = httpclient.execute(httppost);
  75.         } catch (IOException e) {
  76.             e.printStackTrace();
  77.         }
  78.         HttpEntity entity1 = response.getEntity();
  79.         String result = null;
  80.         try {
  81.             result = EntityUtils.toString(entity1);
  82.         } catch (Exception e) {
  83.             e.printStackTrace();
  84.         }
  85.         return result;
  86.     }
  87.  
  88.     /**
  89.      * 发送不带参数的HttpPost请求
  90.      * @param url
  91.      * @return
  92.      */
  93.     public static String sendPost(String url) {
  94.         HttpPost httppost = new HttpPost(url);
  95.         CloseableHttpResponse response = null;
  96.         try {
  97.             response = httpclient.execute(httppost);
  98.         } catch (IOException e) {
  99.             e.printStackTrace();
  100.         }
  101.         HttpEntity entity = response.getEntity();
  102.         String result = null;
  103.         try {
  104.             result = EntityUtils.toString(entity);
  105.         } catch (Exception e) {
  106.             e.printStackTrace();
  107.         }
  108.         return result;
  109.     }
  110.  
  111.     public static String doPost2(String url, JSONObject param) {
  112.         HttpPost httpPost = null;
  113.         String result = null;
  114.         try {
  115.             HttpClient client = new DefaultHttpClient();
  116.             httpPost = new HttpPost(url);
  117.             if (param != null) {
  118.                 StringEntity se = new StringEntity(param.toString(), "utf-8");
  119.                 httpPost.setEntity(se); // post方法中，加入json数据
  120.                 httpPost.setHeader("Content-Type", "application/json");
  121.                 httpPost.setHeader("Authorization", param.getString("authorization"));
  122.             }
  123.  
  124.             HttpResponse response = client.execute(httpPost);
  125.             if (response != null) {
  126.                 HttpEntity resEntity = response.getEntity();
  127.                 if (resEntity != null) {
  128.                     result = EntityUtils.toString(resEntity, "utf-8");
  129.                 }
  130.             }
  131.  
  132.         } catch (Exception ex) {
  133.             ex.printStackTrace();
  134.         }
  135.         return result;
  136.     }
  137. }


5. 腾讯im常用方法工具类TencentCloudImUtil.java

  1. import com.alibaba.fastjson.JSONObject;
  2. import com.example.tencentcloudim.constant.TencentCloudImApiConstant;
  3. import com.example.tencentcloudim.constant.TencentCloudImConstant;
  4. import com.tencentyun.TLSSigAPIv2;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.apache.commons.lang3.RandomUtils;
  7. import org.apache.commons.lang3.StringUtils;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.beans.factory.annotation.Value;
  10. import org.springframework.stereotype.Component;
  11.  
  12. import java.util.ArrayList;
  13. import java.util.List;
  14. import java.util.stream.Collectors;
  15.  
  16. @Slf4j
  17. @Component
  18. public class TencentCloudImUtil {
  19.     private static final String HTTPS_URL_PREFIX = "https://console.tim.qq.com/";
  20.     private static final String APP_MANAGER = "administrator";
  21.     private static final String REDIS_IM_USER_SIG = "silence:im_user_sig:";
  22.  
  23.     @Value("${silence.tencent.cloud.im.sdkAppId}")
  24.     private long sdkAppId;
  25.     @Value("${silence.tencent.cloud.im.key}")
  26.     private String key;
  27.  
  28.     @Autowired
  29.     private RedisServiceUtil redisServiceUtil;
  30.  
  31.     /**
  32.      * 获取腾讯云用户签名
  33.      */
  34.     public String getTxCloudUserSig() {
  35.         String userSig = redisServiceUtil.get(REDIS_IM_USER_SIG + APP_MANAGER);
  36.         if (StringUtils.isEmpty(userSig)) {
  37.             TLSSigAPIv2 tlsSigApi = new TLSSigAPIv2(sdkAppId, key);
  38.             userSig = tlsSigApi.genUserSig(APP_MANAGER, 86400);
  39.             redisServiceUtil.set(REDIS_IM_USER_SIG + APP_MANAGER, userSig, 86400L);
  40.         }
  41.         return userSig;
  42.     }
  43.  
  44.     /**
  45.      * 获取腾讯im请求路径
  46.      */
  47.     private String getHttpsUrl(String imServiceApi, Integer random) {
  48.         return String.format("%s%s?sdkappid=%s&identifier=%s&usersig=%s&random=%s&contenttype=json",
  49.                 HTTPS_URL_PREFIX, imServiceApi, sdkAppId, APP_MANAGER, this.getTxCloudUserSig(), random);
  50.     }
  51.  
  52.     /**
  53.      * 导入单个账号
  54.      * @param userId 用户id
  55.      */
  56.     public void accountImport(String userId) {
  57.         accountImport(userId, null);
  58.     }
  59.  
  60.     public void accountImport(String userId, String userName) {
  61.         accountImport(userId, userName, null);
  62.     }
  63.  
  64.     public void accountImport(String userId, String userName, String faceUrl) {
  65.         Integer random = RandomUtils.nextInt(0, 999999999);
  66.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.AccountManage.ACCOUNT_IMPORT, random);
  67.         JSONObject jsonObject = new JSONObject();
  68.         jsonObject.put("Identifier", userId);
  69.         if (StringUtils.isNotEmpty(userName)) {
  70.             jsonObject.put("Nick", userName);
  71.         }
  72.         if (StringUtils.isNotEmpty(faceUrl)) {
  73.             jsonObject.put("FaceUrl", faceUrl);
  74.         }
  75.         log.info("腾讯云im导入单个账号，请求参数：{}", jsonObject.toString());
  76.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  77.         log.info("腾讯云im导入单个账号，返回结果：{}", result);
  78.     }
  79.  
  80.     /**
  81.      * 导入多个账号
  82.      * @param userIds 用户id集合
  83.      */
  84.     public void multiAccountImport(List<String> userIds) {
  85.         Integer random = RandomUtils.nextInt(0, 999999999);
  86.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.AccountManage.MULTI_ACCOUNT_IMPORT, random);
  87.         JSONObject jsonObject = new JSONObject();
  88.         jsonObject.put("Accounts", userIds);
  89.         log.info("腾讯云im导入多个账号，请求参数：{}", jsonObject.toString());
  90.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  91.         log.info("腾讯云im导入单个账户，返回结果：{}", result);
  92.     }
  93.  
  94.     /**
  95.      * 删除账号
  96.      * @param userIds 用户id集合
  97.      */
  98.     public void accountDelete(List<String> userIds) {
  99.         Integer random = RandomUtils.nextInt(0, 999999999);
  100.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.AccountManage.ACCOUNT_DELETE, random);
  101.         JSONObject jsonObject = new JSONObject();
  102.         jsonObject.put("DeleteItem", getUserIdJsonList(userIds));
  103.         log.info("腾讯云im删除账号，请求参数：{}", jsonObject.toString());
  104.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  105.         log.info("腾讯云im删除账户，返回结果：{}", result);
  106.     }
  107.  
  108.     /**
  109.      * 查询账号是否已经导入im
  110.      * @param userIds 用户id集合
  111.      */
  112.     public String accountCheck(List<String> userIds) {
  113.         Integer random = RandomUtils.nextInt(0, 999999999);
  114.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.AccountManage.ACCOUNT_CHECK, random);
  115.         JSONObject jsonObject = new JSONObject();
  116.         jsonObject.put("CheckItem", getUserIdJsonList(userIds));
  117.         log.info("腾讯云im查询账号，请求参数：{}", jsonObject.toString());
  118.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  119.         log.info("腾讯云im查询账号，返回结果：{}", result);
  120.         return result;
  121.     }
  122.  
  123.     private List<JSONObject> getUserIdJsonList(List<String> userIds) {
  124.         return userIds.stream().map(v -> {
  125.             JSONObject userIdJson = new JSONObject();
  126.             userIdJson.put("UserID", v);
  127.             return userIdJson;
  128.         }).collect(Collectors.toList());
  129.     }
  130.  
  131.     /**
  132.      * 单发单聊消息
  133.      * @param syncOtherMachine 是否同步消息到发送方（1-同步，2-不同步）
  134.      * @param fromUserId 发送方用户id
  135.      * @param toUserId 接收方用户id
  136.      * @param msgType 消息对象类型
  137.      * @param msgContent 消息内容
  138.      */
  139.     public String sendMsg(Integer syncOtherMachine, String fromUserId, String toUserId, String msgType, String msgContent) {
  140.         Integer random = RandomUtils.nextInt(0, 999999999);
  141.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.SingleChatManage.SEND_MSG, random);
  142.         JSONObject jsonObject = new JSONObject();
  143.         jsonObject.put("SyncOtherMachine", syncOtherMachine);
  144.         if (StringUtils.isNotEmpty(fromUserId)) {
  145.             // 发送方不为空表示指定发送用户，为空表示为管理员发送消息
  146.             jsonObject.put("From_Account", fromUserId);
  147.         }
  148.         jsonObject.put("To_Account", toUserId);
  149.         jsonObject.put("MsgRandom", random);
  150.         List<JSONObject> msgBody = getMsgBody(msgType, msgContent);
  151.         jsonObject.put("MsgBody", msgBody);
  152.         log.info("腾讯云im单发单聊消息，请求参数：{}", jsonObject.toString());
  153.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  154.         log.info("腾讯云im单发单聊消息，返回结果：{}", result);
  155.         return result;
  156.     }
  157.  
  158.     /**
  159.      * 批量发单聊消息
  160.      * @param syncOtherMachine 是否同步消息到发送方（1-同步，2-不同步）
  161.      * @param fromUserId 发送方用户id
  162.      * @param toUserIds 接收方用户id集合
  163.      * @param msgType 消息对象类型
  164.      * @param msgContent 消息内容
  165.      */
  166.     public String batchSendMsg(Integer syncOtherMachine, String fromUserId, List<String> toUserIds, String msgType, String msgContent) {
  167.         Integer random = RandomUtils.nextInt(0, 999999999);
  168.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.SingleChatManage.BATCH_SEND_MSG, random);
  169.         JSONObject jsonObject = new JSONObject();
  170.         jsonObject.put("SyncOtherMachine", syncOtherMachine);
  171.         if (StringUtils.isNotEmpty(fromUserId)) {
  172.             // 发送方不为空表示指定发送用户，为空表示为管理员发送消息
  173.             jsonObject.put("From_Account", fromUserId);
  174.         }
  175.         jsonObject.put("To_Account", toUserIds);
  176.         jsonObject.put("MsgRandom", random);
  177.         List<JSONObject> msgBody = getMsgBody(msgType, msgContent);
  178.         jsonObject.put("MsgBody", msgBody);
  179.         log.info("腾讯云im批量发单聊消息，请求参数：{}", jsonObject.toString());
  180.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  181.         log.info("腾讯云im批量发单聊消息，返回结果：{}", result);
  182.         return result;
  183.     }
  184.  
  185.  
  186.     /**
  187.      * 拼接发送消息内容
  188.      * @param msgType 消息类型
  189.      * @param msgContent 发送消息内容
  190.      * @return 消息内容
  191.      */
  192.     private List<JSONObject> getMsgBody(String msgType, String msgContent) {
  193.         List<JSONObject> msgBody = new ArrayList<>();
  194.         if (msgType.equals(TencentCloudImConstant.TIM_TEXT_ELEM)) {
  195.             // 文本类型
  196.             JSONObject msgBodyJson = new JSONObject();
  197.             msgBodyJson.put("MsgType", msgType);
  198.             JSONObject msgContentObj = new JSONObject();
  199.             msgContentObj.put("Text", msgContent);
  200.             msgBodyJson.put("MsgContent", msgContentObj);
  201.             msgBody.add(msgBodyJson);
  202.         }
  203.         return msgBody;
  204.     }
  205.  
  206.     /**
  207.      * 查询单聊消息
  208.      * @param fromUserId 发送方用户id
  209.      * @param toUserId 接收方用户id
  210.      * @param maxCnt 查询条数
  211.      * @param startTime 起始时间（单位：秒）
  212.      * @param endTime 结束时间（单位：秒）
  213.      * @param lastMsgKey 最后一条消息的 MsgKey
  214.      * @return 单聊消息列表
  215.      */
  216.     public String adminGetRoamMsg(String fromUserId, String toUserId, Integer maxCnt, Long startTime, Long endTime, String lastMsgKey) {
  217.         Integer random = RandomUtils.nextInt(0, 999999999);
  218.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.SingleChatManage.ADMIN_GET_ROAM_MSG, random);
  219.         JSONObject jsonObject = new JSONObject();
  220.         jsonObject.put("From_Account", fromUserId);
  221.         jsonObject.put("To_Account", toUserId);
  222.         jsonObject.put("MaxCnt", maxCnt);
  223.         jsonObject.put("MinTime", startTime);
  224.         jsonObject.put("MaxTime", endTime);
  225.         if (StringUtils.isNotEmpty(lastMsgKey)){
  226.             jsonObject.put("LastMsgKey", lastMsgKey);
  227.         }
  228.         log.info("腾讯云im查询单聊消息，请求参数：{}", jsonObject.toString());
  229.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  230.         log.info("腾讯云im查询单聊消息，返回结果：{}", result);
  231.         return result;
  232.     }
  233.  
  234.     /**
  235.      * 撤回单聊消息
  236.      * @param fromUserId 发送方用户id
  237.      * @param toUserId 接收方用户id
  238.      * @param msgKey MsgKey
  239.      */
  240.     public void adminMsgWithDraw(String fromUserId, String toUserId, String msgKey) {
  241.         Integer random = RandomUtils.nextInt(0, 999999999);
  242.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.SingleChatManage.ADMIN_MSG_WITH_DRAW, random);
  243.         JSONObject jsonObject = new JSONObject();
  244.         jsonObject.put("From_Account", fromUserId);
  245.         jsonObject.put("To_Account", toUserId);
  246.         jsonObject.put("MsgKey", msgKey);
  247.         log.info("腾讯云im撤回单聊消息，请求参数：{}", jsonObject.toString());
  248.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  249.         log.info("腾讯云im撤回单聊消息，返回结果：{}", result);
  250.     }
  251.  
  252.     /**
  253.      * 设置单聊消息已读
  254.      * @param reportUserId 读取消息的用户
  255.      * @param peerUserId 发送消息的用户
  256.      */
  257.     public void adminSetMsgRead(String reportUserId, String peerUserId) {
  258.         Integer random = RandomUtils.nextInt(0, 999999999);
  259.         String httpsUrl = getHttpsUrl(TencentCloudImApiConstant.SingleChatManage.ADMIN_SET_MSG_READ, random);
  260.         JSONObject jsonObject = new JSONObject();
  261.         jsonObject.put("Report_Account", reportUserId);
  262.         jsonObject.put("Peer_Account", peerUserId);
  263.         log.info("腾讯云im设置单聊消息已读，请求参数：{}", jsonObject.toString());
  264.         String result = HttpUtil.doPost2(httpsUrl, jsonObject);
  265.         log.info("腾讯云im设置单聊消息已读，返回结果：{}", result);
  266.     }
  267. }

 

 

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/花生_TL007/article/detail/178587
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号