From c98507d9a02321ae08deaf199d068f0de3330d79 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Wed, 4 Mar 2026 19:16:35 +0800 Subject: [PATCH] =?UTF-8?q?sdk=E6=B5=8B=E8=AF=95=E6=96=B9=E6=B3=95?= =?UTF-8?q?=E4=B8=AD=E6=B7=BB=E5=8A=A0=E6=9B=B4=E5=A4=9A=E7=9A=84=E6=B5=8B?= =?UTF-8?q?=E8=AF=95=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/cn/wildfirechat/sdk/Main.java | 568 +++++++++++++++++- 1 file changed, 561 insertions(+), 7 deletions(-) diff --git a/sdk/src/main/java/cn/wildfirechat/sdk/Main.java b/sdk/src/main/java/cn/wildfirechat/sdk/Main.java index 6ab665b0..7d825a31 100644 --- a/sdk/src/main/java/cn/wildfirechat/sdk/Main.java +++ b/sdk/src/main/java/cn/wildfirechat/sdk/Main.java @@ -1,6 +1,9 @@ package cn.wildfirechat.sdk; import cn.wildfirechat.common.ErrorCode; +import cn.wildfirechat.pojos.mesh.PojoDomainPingResponse; +import cn.wildfirechat.pojos.mesh.PojoSearchUserRes; +import cn.wildfirechat.pojos.mesh.PojoUserConferenceResponse; import cn.wildfirechat.pojos.moments.CommentPojo; import cn.wildfirechat.pojos.moments.FeedPojo; import cn.wildfirechat.pojos.moments.FeedsPojo; @@ -94,6 +97,9 @@ public class Main { testRobot(); // 测试频道功能 testChannel(); + + //测试Mesh相关API，用于分布式IM。Mesh相关测试依赖环境，不具备测绘条件，注释掉。 + //testMesh(); } @@ -423,6 +429,15 @@ public class Main { System.exit(-1); } + //测试踢下线用户客户端 + IMResult kickoffResult = UserAdmin.kickoffUserClient(userInfo.getUserId(), null); + if (kickoffResult != null && kickoffResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("kickoff user client success"); + } else { + System.out.println("kickoff user client failure"); + System.exit(-1); + } + //慎用，这个方法可能功能不完全，如果用户不在需要，建议使用block功能屏蔽用户 // 销毁用户（物理删除，不可恢复） IMResult voidIMResult = UserAdmin.destroyUser("user11"); @@ -634,6 +649,15 @@ public class Main { System.out.println("set friend extra failure"); System.exit(-1); } + + //测试获取用户的机器人列表 + IMResult userRobotsResult = UserAdmin.getUserRobots("ff1"); + if (userRobotsResult != null && userRobotsResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("get user robots success"); + } else { + System.out.println("get user robots failure"); + System.exit(-1); + } } //*********************************************** //**** 群组相关功能 @@ -868,6 +892,60 @@ public class Main { System.exit(-1); } + //测试批量获取群组信息 + IMResult batchGroupInfoResult = GroupAdmin.batchGroupInfos(Arrays.asList(groupInfo.getTarget_id())); + if (batchGroupInfoResult != null && batchGroupInfoResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("batch get group info success"); + } else { + System.out.println("batch get group info failure"); + System.exit(-1); + } + + //测试群备注功能 + String groupRemark = "test group remark"; + IMResult setGroupRemarkResult = GroupAdmin.setGroupRemark("user1", groupInfo.getTarget_id(), groupRemark); + if (setGroupRemarkResult != null && setGroupRemarkResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set group remark success"); + } else { + System.out.println("set group remark failure"); + System.exit(-1); + } + + IMResult getGroupRemarkResult = GroupAdmin.getGroupRemark("user1", groupInfo.getTarget_id()); + if (getGroupRemarkResult != null && getGroupRemarkResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && groupRemark.equals(getGroupRemarkResult.getResult())) { + System.out.println("get group remark success"); + } else { + System.out.println("get group remark failure"); + System.exit(-1); + } + + //测试收藏群功能 + IMResult setFavGroupResult = GroupAdmin.setFavGroup("user1", groupInfo.getTarget_id(), true); + if (setFavGroupResult != null && setFavGroupResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set fav group success"); + } else { + System.out.println("set fav group failure"); + System.exit(-1); + } + + Thread.sleep(1000); + IMResult isFavGroupResult = GroupAdmin.isFavGroup("user1", groupInfo.getTarget_id()); + if (isFavGroupResult != null && isFavGroupResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && isFavGroupResult.getResult()) { + System.out.println("is fav group success"); + } else { + System.out.println("is fav group failure"); + System.exit(-1); + } + + //取消收藏 + setFavGroupResult = GroupAdmin.setFavGroup("user1", groupInfo.getTarget_id(), false); + if (setFavGroupResult != null && setFavGroupResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("cancel fav group success"); + } else { + System.out.println("cancel fav group failure"); + System.exit(-1); + } + //仅专业版支持 if (commercialServer) { //开启群成员禁言 @@ -905,6 +983,24 @@ public class Main { System.exit(-1); } } + + //测试解散群组 + IMResult dismissGroupResult = GroupAdmin.dismissGroup("user2", groupInfo.getTarget_id(), null, null); + if (dismissGroupResult != null && dismissGroupResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("dismiss group success"); + } else { + System.out.println("dismiss group failure"); + System.exit(-1); + } + + //验证群组已被解散 + resultGetGroupInfo = GroupAdmin.getGroupInfo(groupInfo.getTarget_id()); + if (resultGetGroupInfo != null && resultGetGroupInfo.getErrorCode() == ErrorCode.ERROR_CODE_NOT_EXIST) { + System.out.println("group dismissed verified"); + } else { + System.out.println("group dismiss verify failure"); + System.exit(-1); + } } //*********************************************** @@ -1006,6 +1102,14 @@ public class Main { System.out.println("failure"); } + //测试删除广播消息 + IMResult deleteBroadCastResult = MessageAdmin.deleteBroadCastMessage("user1", resultBroadcastMessage.result.getMessageUid()); + if (deleteBroadCastResult != null && deleteBroadCastResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("delete broadcast message success"); + } else { + System.out.println("delete broadcast message failure"); + } + IMResult timestampResult = MessageAdmin.getConversationReadTimestamp("57gqmws2k", new Conversation(0, "admin", 0)); if(timestampResult != null && timestampResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("Get conversation read time success"); @@ -1030,6 +1134,14 @@ public class Main { } else { System.out.println("clear conversation failure"); } + + //测试清空用户消息 + IMResult clearUserMessagesResult = MessageAdmin.clearUserMessages("user1", conversation, 0, System.currentTimeMillis()); + if (clearUserMessagesResult != null && clearUserMessagesResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("clear user messages success"); + } else { + System.out.println("clear user messages failure"); + } } List multicastReceivers = Arrays.asList("user2", "user3", "user4"); @@ -1048,6 +1160,14 @@ public class Main { System.out.println("failure"); } + //测试删除多播消息 + IMResult deleteMultiCastResult = MessageAdmin.deleteMultiCastMessage("user1", resultMulticastMessage.result.getMessageUid(), multicastReceivers); + if (deleteMultiCastResult != null && deleteMultiCastResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("delete multicast message success"); + } else { + System.out.println("delete multicast message failure"); + } + } //*********************************************** @@ -1509,6 +1629,80 @@ public class Main { System.out.println("health check failure"); System.exit(-1); } + + + //测试用户设置功能 + IMResult setUserSettingResult = GeneralAdmin.setUserSetting("user1", 1, "test_key", "test_value"); + if (setUserSettingResult != null && setUserSettingResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set user setting success"); + } else { + System.out.println("set user setting failure"); + System.exit(-1); + } + + IMResult getUserSettingResult = GeneralAdmin.getUserSetting("user1", 1, "test_key"); + if (getUserSettingResult != null && getUserSettingResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && "test_value".equals(getUserSettingResult.getResult().getValue())) { + System.out.println("get user setting success"); + } else { + System.out.println("get user setting failure"); + System.exit(-1); + } + + if (commercialServer) { + //测试会话置顶功能 + IMResult setTopResult = GeneralAdmin.setConversationTop("user1", ProtoConstants.ConversationType.ConversationType_Private, "user2", 0, true); + if (setTopResult != null && setTopResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set conversation top success"); + } else { + System.out.println("set conversation top failure"); + System.exit(-1); + } + + Thread.sleep(1000); + IMResult getTopResult = GeneralAdmin.getConversationTop("user1", ProtoConstants.ConversationType.ConversationType_Private, "user2", 0); + if (getTopResult != null && getTopResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && getTopResult.getResult()) { + System.out.println("get conversation top success"); + } else { + System.out.println("get conversation top failure"); + System.exit(-1); + } + + //取消置顶 + setTopResult = GeneralAdmin.setConversationTop("user1", ProtoConstants.ConversationType.ConversationType_Private, "user2", 0, false); + if (setTopResult != null && setTopResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("cancel conversation top success"); + } else { + System.out.println("cancel conversation top failure"); + System.exit(-1); + } + + //测试获取会话文件 + IMResult getConversationFilesResult = GeneralAdmin.getConversationFiles(ProtoConstants.ConversationType.ConversationType_Private, "user2", 0, "user1", 0, true, 10); + if (getConversationFilesResult != null && getConversationFilesResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("get conversation files success"); + } else { + System.out.println("get conversation files failure"); + } + + //测试获取用户文件 + IMResult getUserFilesResult = GeneralAdmin.getUserFiles("user1", 0, true, 10); + if (getUserFilesResult != null && getUserFilesResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("get user files success"); + } else { + System.out.println("get user files failure"); + } + + //测试获取单个文件信息 + if (getUserFilesResult.getResult() != null && getUserFilesResult.getResult().files != null && !getUserFilesResult.getResult().files.isEmpty()) { + long messageId = getUserFilesResult.getResult().files.get(0).messageId; + IMResult getFileResult = GeneralAdmin.getFile(messageId); + if (getFileResult != null && getFileResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("get file success"); + } else { + System.out.println("get file failure"); + } + } + } } /** @@ -1592,6 +1786,24 @@ public class Main { System.exit(-1); } + //测试设置聊天室全局禁言 + IMResult setChatroomMuteResult = ChatroomAdmin.setChatroomMute(chatroomId, true); + if (setChatroomMuteResult != null && setChatroomMuteResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set chatroom mute success"); + } else { + System.out.println("set chatroom mute failure"); + System.exit(-1); + } + + //取消聊天室全局禁言 + setChatroomMuteResult = ChatroomAdmin.setChatroomMute(chatroomId, false); + if (setChatroomMuteResult != null && setChatroomMuteResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("cancel chatroom mute success"); + } else { + System.out.println("cancel chatroom mute failure"); + System.exit(-1); + } + //下面仅专业版支持 if(commercialServer) { //设置用户聊天室黑名单。0正常；1禁言；2禁止加入。 @@ -1787,6 +1999,7 @@ public class Main { System.exit(-1); } + //测试删除机器人回调地址 voidIMResult1 = robotService.deleteCallback(); if(voidIMResult1 != null && voidIMResult1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("delete callback success"); @@ -1795,6 +2008,7 @@ public class Main { System.exit(-1); } + //验证回调地址已删除 callbackPojoIMResult = robotService.getCallback(); if(callbackPojoIMResult != null && callbackPojoIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && StringUtil.isNullOrEmpty(callbackPojoIMResult.getResult().getUrl())) { System.out.println("get callback success"); @@ -1803,13 +2017,17 @@ public class Main { System.exit(-1); } + //创建会话对象，设置目标用户和会话类型 Conversation conversation = new Conversation(); conversation.setTarget("user2"); conversation.setType(ProtoConstants.ConversationType.ConversationType_Private); + + //创建消息payload，设置消息类型和内容 MessagePayload payload = new MessagePayload(); payload.setType(1); payload.setSearchableContent("hello world"); + //测试机器人发送消息 IMResult resultRobotSendMessage = robotService.sendMessage(robotService.getRobotId(), conversation, payload); if (resultRobotSendMessage != null && resultRobotSendMessage.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("robot send message success"); @@ -1818,6 +2036,14 @@ public class Main { System.exit(-1); } + //测试机器人回复消息 + IMResult replyMessageResult = robotService.replyMessage(resultRobotSendMessage.getResult().getMessageUid(), payload, false); + if (replyMessageResult != null && replyMessageResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("robot reply message success"); + } else { + System.out.println("robot reply message failure"); + } + if(commercialServer) { Thread.sleep(1000); IMResult recallMessageResult = robotService.recallMessage(resultRobotSendMessage.result.getMessageUid()); @@ -1849,6 +2075,7 @@ public class Main { } + //测试机器人通过用户ID获取用户信息 IMResult resultRobotGetUserInfo = robotService.getUserInfo("userId1"); if (resultRobotGetUserInfo != null && resultRobotGetUserInfo.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("robot get user info success"); @@ -1857,6 +2084,23 @@ public class Main { System.exit(-1); } + //测试机器人通过手机号获取用户信息 + IMResult resultRobotGetUserInfoByMobile = robotService.getUserInfoByMobile("13900000000"); + if (resultRobotGetUserInfoByMobile != null && resultRobotGetUserInfoByMobile.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("robot get user info by mobile success"); + } else { + System.out.println("robot get user info by mobile failure"); + } + + //测试机器人通过用户名获取用户信息 + IMResult resultRobotGetUserInfoByName = robotService.getUserInfoByName("user1"); + if (resultRobotGetUserInfoByName != null && resultRobotGetUserInfoByName.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("robot get user info by name success"); + } else { + System.out.println("robot get user info by name failure"); + } + + //创建群组信息，用于测试机器人群组管理功能 String groupId = "robot_group" + System.currentTimeMillis(); PojoGroupInfo groupInfo = new PojoGroupInfo(); groupInfo.setTarget_id(groupId); @@ -1878,6 +2122,7 @@ public class Main { member3.setMember_id("user3"); members.add(member3); + //测试机器人创建群组 IMResult resultCreateGroup = robotService.createGroup(groupInfo, members, null, null, null); if (resultCreateGroup != null && resultCreateGroup.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("create group success"); @@ -1954,6 +2199,15 @@ public class Main { System.exit(-1); } + //测试设置群成员extra + voidIMResult = robotService.setGroupMemberExtra(groupInfo.getTarget_id(), "user2", "robot member extra", null, null); + if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("set group member extra success"); + } else { + System.out.println("set group member extra failure"); + System.exit(-1); + } + if(commercialServer) { PojoGroupMember m4 = new PojoGroupMember(); m4.setMember_id("user4"); @@ -1987,6 +2241,23 @@ public class Main { System.exit(-1); } + + //测试机器人应用获取用户信息。authCode应该是从客户端SDK里获取到的，这里不具备条件，跳过测试 +// IMResult appGetUserInfoResult = robotService.applicationGetUserInfo("test_auth_code"); +// if (appGetUserInfoResult != null && (appGetUserInfoResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS || appGetUserInfoResult.getErrorCode() == ErrorCode.ERROR_CODE_INVALID_DATA)) { +// System.out.println("robot application get user info success"); +// } else { +// System.out.println("robot application get user info failure"); +// } + + //测试机器人发送会议请求。不具备测试条件，注释掉。 +// IMResult sendConferenceRequestResult = robotService.sendConferenceRequest(robotId, "client1", "test_request", 1, "room1", "test_data", false); +// if (sendConferenceRequestResult != null && (sendConferenceRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS || sendConferenceRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_INVALID_DATA)) { +// System.out.println("robot send conference request success"); +// } else { +// System.out.println("robot send conference request failure"); +// } + OutputApplicationConfigData config = robotService.getApplicationSignature(); System.out.println(config); } @@ -2028,6 +2299,7 @@ public class Main { System.exit(-1); } } + //测试机器人转让群组给user2 voidIMResult = robotService.transferGroup(groupInfo.getTarget_id(), "user2", null, null); if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("transfer success"); @@ -2036,6 +2308,7 @@ public class Main { System.exit(-1); } + //验证群组转让成功，检查新群主是否为user2 resultGetGroupInfo = robotService.getGroupInfo(groupInfo.getTarget_id()); if (resultGetGroupInfo != null && resultGetGroupInfo.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { if ("user2".equals(resultGetGroupInfo.getResult().getOwner())) { @@ -2049,6 +2322,7 @@ public class Main { System.exit(-1); } + //测试机器人退出群组 voidIMResult = robotService.quitGroup(groupInfo.getTarget_id(), null, null); if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("quit group success"); @@ -2138,9 +2412,45 @@ public class Main { System.out.println("get user moments profile failure:" + profileResult.getErrorCode().code); System.exit(-1); } + + //测试更新朋友圈设置 + IMResult updateBgResult = robotService.updateMomentsBackgroundUrl("https://example.com/bg.jpg"); + if (updateBgResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("update moments background success"); + } else { + System.out.println("update moments background failure:" + updateBgResult.getErrorCode().code); + } + + IMResult updateVisibleCountResult = robotService.updateMomentsStrangerVisibleCount(10); + if (updateVisibleCountResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("update moments visible count success"); + } else { + System.out.println("update moments visible count failure:" + updateVisibleCountResult.getErrorCode().code); + } + + IMResult updateVisibleScopeResult = robotService.updateMomentsVisibleScope(0); + if (updateVisibleScopeResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("update moments visible scope success"); + } else { + System.out.println("update moments visible scope failure:" + updateVisibleScopeResult.getErrorCode().code); + } + + IMResult updateBlackListResult = robotService.updateMomentsBlackList(Arrays.asList("user1"), null); + if (updateBlackListResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("update moments blacklist success"); + } else { + System.out.println("update moments blacklist failure:" + updateBlackListResult.getErrorCode().code); + } + + IMResult updateBlockListResult = robotService.updateMomentsBlockList(Arrays.asList("user2"), null); + if (updateBlockListResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("update moments blocklist success"); + } else { + System.out.println("update moments blocklist failure:" + updateBlockListResult.getErrorCode().code); + } } - //使用完需要释放 + //释放机器人服务资源 robotService.close(); } @@ -2238,6 +2548,8 @@ public class Main { //3. 测试channel api功能 + + //测试用户关注频道 IMResult resultVoid = channelServiceApi.subscribe("userId2"); if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("subscribe success"); @@ -2246,6 +2558,7 @@ public class Main { System.exit(-1); } + //测试另一个用户关注频道 resultVoid = channelServiceApi.subscribe("userId3"); if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("subscribe done"); @@ -2254,6 +2567,7 @@ public class Main { System.exit(-1); } + //使用Admin API让userId4关注频道 resultVoid = ChannelAdmin.subscribeChannel(channelId, "userId4"); if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("subscribe done"); @@ -2262,6 +2576,7 @@ public class Main { System.exit(-1); } + //获取频道订阅者列表 IMResult resultStringList = channelServiceApi.getSubscriberList(); if (resultStringList != null && resultStringList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultStringList.getResult().getList().contains("userId2") && resultStringList.getResult().getList().contains("userId3") && resultStringList.getResult().getList().contains("userId4")) { System.out.println("get subscriber done"); @@ -2270,6 +2585,7 @@ public class Main { System.exit(-1); } + //检查用户是否订阅了频道 IMResult booleanIMResult = channelServiceApi.isSubscriber("userId2"); if(booleanIMResult != null && booleanIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && booleanIMResult.getResult()) { System.out.println("is subscriber success"); @@ -2278,6 +2594,7 @@ public class Main { System.exit(-1); } + //测试用户取消关注频道 resultVoid = channelServiceApi.unsubscribe("userId2"); if (resultVoid != null && resultVoid.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("unsubscriber done"); @@ -2286,6 +2603,7 @@ public class Main { System.exit(-1); } + //验证userId2已不在订阅者列表中 resultStringList = channelServiceApi.getSubscriberList(); if (resultStringList != null && resultStringList.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && resultStringList.getResult().getList().contains("userId3") && !resultStringList.getResult().getList().contains("userId2")) { System.out.println("get subscriber done"); @@ -2294,6 +2612,7 @@ public class Main { System.exit(-1); } + //测试频道获取用户信息 IMResult resultGetUserInfo1 = channelServiceApi.getUserInfo("userId3"); if (resultGetUserInfo1 != null && resultGetUserInfo1.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("get user info success"); @@ -2302,6 +2621,7 @@ public class Main { System.exit(-1); } + //创建消息payload MessagePayload payload = new MessagePayload(); payload.setType(1); payload.setSearchableContent("hello world"); @@ -2314,6 +2634,15 @@ public class Main { System.exit(-1); } + //测试重新发布消息 + IMResult republishResult = channelServiceApi.republishMessage(resultSendMessage.getResult().getMessageUid(), Arrays.asList("userId2", "userId3")); + if (republishResult != null && republishResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("republish message success"); + } else { + System.out.println("republish message failure"); + System.exit(-1); + } + ArticleContent articleContent = new ArticleContent("article1", "https://media.wfcoss.cn/channel-assets/20220816/2dd76540daa9444dae44e942aa1c2bbc.png", "这是一个测试文章", "测试一下文章的功能", "https://mp.weixin.qq.com/s/W6tanLbALd3qqZM8r3MTgA", true); articleContent.addSubArticle("article2", "https://media.wfcoss.cn/channel-assets/20220816/2dd76540daa9444dae44e942aa1c2bbc.png", "这是第二个测试文章", "测试一下文章的功能", "https://mp.weixin.qq.com/s/W6tanLbALd3qqZM8r3MTgA", false); articleContent.addSubArticle("article3", "https://media.wfcoss.cn/channel-assets/20220816/2dd76540daa9444dae44e942aa1c2bbc.png", "这是第三个测试文章", "测试一下文章的功能", "https://mp.weixin.qq.com/s/W6tanLbALd3qqZM8r3MTgA", false); @@ -2327,6 +2656,7 @@ public class Main { System.exit(-1); } + //发送定向消息给指定用户 payload.setSearchableContent("hello to user2"); resultSendMessage = channelServiceApi.sendMessage(0, Arrays.asList("userId2"),payload); @@ -2337,6 +2667,7 @@ public class Main { System.exit(-1); } + //测试修改频道描述信息 IMResult voidIMResult = channelServiceApi.modifyChannelInfo(ProtoConstants.ModifyChannelInfoType.Modify_Channel_Desc, "this is a test channel, update at:" + new Date().toString()); if (voidIMResult != null && voidIMResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("modify channel profile success"); @@ -2387,6 +2718,22 @@ public class Main { System.out.println("get channel info failure"); System.exit(-1); } + + //测试修改频道菜单 + List testMenus = new ArrayList<>(); + PojoChannelMenu testMenu = new PojoChannelMenu(); + testMenu.menuId = UUID.randomUUID().toString(); + testMenu.type = "view"; + testMenu.name = "测试菜单"; + testMenu.key = "test_key"; + testMenu.url = "http://www.test.com"; + testMenus.add(testMenu); + IMResult modifyMenuResult = channelServiceApi.modifyChannelMenu(testMenus); + if (modifyMenuResult != null && modifyMenuResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("modify channel menu success"); + } else { + System.out.println("modify channel menu failure"); + } OutputApplicationConfigData config = channelServiceApi.getApplicationSignature(); System.out.println(config); @@ -2489,9 +2836,12 @@ public class Main { * @throws Exception 当测试过程中发生错误时抛出异常 */ static void testDevice() throws Exception { + //创建设备信息，设置设备ID和所有者列表 InputCreateDevice createDevice = new InputCreateDevice(); createDevice.setDeviceId("deviceId1"); createDevice.setOwners(Arrays.asList("opoGoG__", "userId1")); + + //测试创建设备（如果不存在则创建，存在则更新） IMResult resultCreateDevice = UserAdmin.createOrUpdateDevice(createDevice); if (resultCreateDevice != null && resultCreateDevice.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("Create device " + resultCreateDevice.getResult().getDeviceId() + " success"); @@ -2500,6 +2850,7 @@ public class Main { System.exit(-1); } + //测试获取设备信息 IMResult getDevice = UserAdmin.getDevice("deviceId1"); if (getDevice != null && getDevice.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS && getDevice.getResult().getDeviceId().equals("deviceId1") && getDevice.getResult().getOwners().contains("opoGoG__")) { System.out.println("Get device " + resultCreateDevice.getResult().getDeviceId() + " success"); @@ -2508,6 +2859,7 @@ public class Main { System.exit(-1); } + //测试获取用户绑定的所有设备 IMResult getUserDevices = UserAdmin.getUserDevices("userId1"); if (getUserDevices != null && getUserDevices.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { boolean success = false; @@ -2529,10 +2881,25 @@ public class Main { } } - /* - 会议相关接口，仅音视频高级版服务支持 + /** + * 会议功能测试（仅音视频高级版服务支持） + *

+ * 测试以下会议功能： + *

    + *
  • 获取会议列表
    • + *
  • 销毁会议
    • + *
  • 创建普通会议
    • + *
  • 创建高级会议
    • + *
  • 检查会议是否存在
    • + *
  • 开启会议录制
    • + *
  • 获取参会者列表
    • + *
  • RTP转发相关操作
    • + *
+ *

+ * @throws Exception 当测试过程中发生错误时抛出异常 */ public static void testConference() throws Exception { + //获取当前会议列表 IMResult listResult = ConferenceAdmin.listConferences(100, 0); if(listResult == null || listResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("get conference list failure"); @@ -2541,6 +2908,7 @@ public class Main { System.out.println("conference list " + listResult.getResult().conferenceInfoList); } + //清理现有会议，避免影响测试 for (PojoConferenceInfo conferenceInfo:listResult.getResult().conferenceInfoList) { IMResult destroyResult = ConferenceAdmin.destroy(conferenceInfo.roomId, conferenceInfo.advance); if(destroyResult == null || destroyResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { @@ -2551,6 +2919,7 @@ public class Main { } } + //再次获取会议列表，确认已清空 listResult = ConferenceAdmin.listConferences(100, 0); if(listResult == null || listResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("get conference list failure"); @@ -2559,7 +2928,11 @@ public class Main { System.out.println("conference list " + listResult.getResult().conferenceInfoList); } - IMResult voidIMResult = ConferenceAdmin.createRoom("helloroomid", "hello room description", "123456", 9, false, 0, false, true); + //生成两个会议房间ID + String roomId1 = UUID.randomUUID().toString(); + String roomId2 = UUID.randomUUID().toString(); + //创建普通会议房间（非高级版，最多9人） + IMResult voidIMResult = ConferenceAdmin.createRoom(roomId1, "hello room description", "123456", 9, false, 0, false, true); if(voidIMResult == null || voidIMResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("create conference failure"); System.exit(-1); @@ -2567,7 +2940,8 @@ public class Main { System.out.println("create conference"); } - voidIMResult = ConferenceAdmin.createRoom("helloroomid2", "hello room description advanced", "123456", 20, true, 0, false, true); + //创建高级会议房间（支持更多功能，最多20人） + voidIMResult = ConferenceAdmin.createRoom(roomId2, "hello room description advanced", "123456", 20, true, 0, false, true); if(voidIMResult == null || voidIMResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("create conference failure"); System.exit(-1); @@ -2575,7 +2949,8 @@ public class Main { System.out.println("create conference"); } - IMResult booleanIMResult = ConferenceAdmin.existsConferences("helloroomid2"); + //检查会议房间是否存在 + IMResult booleanIMResult = ConferenceAdmin.existsConferences(roomId1); if(booleanIMResult == null || booleanIMResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("exist conference failure"); System.exit(-1); @@ -2583,7 +2958,8 @@ public class Main { System.out.println("exit conference success"); } - voidIMResult = ConferenceAdmin.enableRecording("helloroomid2", true, true); + //开启会议录制功能（视频和音频都录制） + voidIMResult = ConferenceAdmin.enableRecording(roomId2, true, true); if(voidIMResult == null || voidIMResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("recording conference failure"); System.exit(-1); @@ -2599,6 +2975,7 @@ public class Main { System.out.println("conference list " + listResult.getResult().conferenceInfoList); } + //获取每个会议的参会者列表 for (PojoConferenceInfo conferenceInfo:listResult.getResult().conferenceInfoList) { IMResult listParticipantsResult = ConferenceAdmin.listParticipants(conferenceInfo.roomId, conferenceInfo.advance); if(listParticipantsResult == null || listParticipantsResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { @@ -2609,6 +2986,7 @@ public class Main { } } + //获取RTP转发器列表，并停止所有转发 IMResult listForwarderResult = ConferenceAdmin.listRtpForwarders("6366963312"); if(listForwarderResult == null || listForwarderResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("list rtp forward failure"); @@ -2628,6 +3006,7 @@ public class Main { })); } + //测试RTP转发功能，将媒体流转发到指定地址 IMResult rtpForwardResult = ConferenceAdmin.rtpForward("6366963312", "cygqmws2k", "192.168.1.81", 10000, 111, 0, 10005, 98, 0); if(rtpForwardResult == null || rtpForwardResult.getErrorCode() != ErrorCode.ERROR_CODE_SUCCESS) { System.out.println("rtp forward failure"); @@ -2635,4 +3014,179 @@ public class Main { System.out.println("rtp forward success"); } } + + //*********************************************** + //**** Mesh相关API，用于分布式IM + //*********************************************** + /** + * Mesh（分布式IM）API测试 + *

+ * 测试以下分布式IM功能： + *

    + *
  • 搜索用户 - 跨域搜索用户
    • + *
  • 批量获取用户信息 - 获取多个用户的详细信息
    • + *
  • 发送好友请求 - 向其他域用户发送好友请求
    • + *
  • 处理好友请求 - 接受或拒绝好友请求
    • + *
  • 创建域 - 创建新的Mesh域
    • + *
  • 获取域信息 - 获取指定域的详细信息
    • + *
  • 获取所有域 - 获取Mesh网络中的所有域列表
    • + *
  • Ping域 - 测试域的连通性
    • + *
  • 删除域 - 从Mesh网络中移除域
    • + *
  • 同步群组 - 跨域同步群组信息
    • + *
  • 发送消息 - 向其他域用户发送消息
    • + *
  • 发布消息 - 向多个域用户广播消息
    • + *
  • 添加加入群组请求 - 跨域申请加入群组
    • + *
  • 会议用户请求 - 跨域会议相关请求
    • + *
  • 会议用户事件 - 跨域会议事件处理
    • + *
+ *

+ * @throws Exception 当测试过程中发生错误时抛出异常 + */ + static void testMesh() throws Exception { + //测试搜索用户 + IMResult searchUserResult = MeshAdmin.searchUser("test", 0, 0, 1); + if (searchUserResult != null && searchUserResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh search user success"); + } else { + System.out.println("mesh search user failure"); + } + + //测试批量获取用户信息 + IMResult batchUserInfosResult = MeshAdmin.getBatchUserInfos(Arrays.asList("user1", "user2")); + if (batchUserInfosResult != null && batchUserInfosResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh batch get user info success"); + } else { + System.out.println("mesh batch get user info failure"); + } + + //测试发送好友请求 + IMResult sendFriendRequestResult = MeshAdmin.sendFriendRequest("user1", "user2", "hello"); + if (sendFriendRequestResult != null && (sendFriendRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS || sendFriendRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_ALREADY_FRIENDS)) { + System.out.println("mesh send friend request success"); + } else { + System.out.println("mesh send friend request failure"); + } + + //测试处理好友请求 + IMResult handleFriendRequestResult = MeshAdmin.handleFriendRequest("user2", "user1", 1); + if (handleFriendRequestResult != null && handleFriendRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh handle friend request success"); + } else { + System.out.println("mesh handle friend request failure"); + } + + //测试创建域 + String domainId = "test_domain_" + System.currentTimeMillis(); + InputOutputDomainInfo domainInfo = new InputOutputDomainInfo(); + domainInfo.setDomainId(domainId); + domainInfo.setName("Test Domain"); + IMResult createDomainResult = MeshAdmin.createDomain(domainInfo); + if (createDomainResult != null && createDomainResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh create domain success"); + } else { + System.out.println("mesh create domain failure"); + } + + //测试获取域 + IMResult getDomainResult = MeshAdmin.getDomain(domainId); + if (getDomainResult != null && getDomainResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh get domain success"); + } else { + System.out.println("mesh get domain failure"); + } + + //测试获取所有域 + IMResult getAllDomainResult = MeshAdmin.getAllDomain(); + if (getAllDomainResult != null && getAllDomainResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh get all domain success"); + } else { + System.out.println("mesh get all domain failure"); + } + + //测试ping域 + IMResult pingDomainResult = MeshAdmin.pingDomain(domainId); + if (pingDomainResult != null && pingDomainResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh ping domain success"); + } else { + System.out.println("mesh ping domain failure"); + } + + //测试删除域 + IMResult deleteDomainResult = MeshAdmin.deleteDomain(domainId); + if (deleteDomainResult != null && deleteDomainResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh delete domain success"); + } else { + System.out.println("mesh delete domain failure"); + } + + //测试同步群组 + PojoGroupInfo meshGroupInfo = new PojoGroupInfo(); + meshGroupInfo.setTarget_id("mesh_group_" + System.currentTimeMillis()); + meshGroupInfo.setName("Mesh Test Group"); + meshGroupInfo.setOwner("user1"); + meshGroupInfo.setType(2); + List meshMembers = new ArrayList<>(); + PojoGroupMember meshMember = new PojoGroupMember(); + meshMember.setMember_id("user1"); + meshMembers.add(meshMember); + IMResult syncGroupResult = MeshAdmin.syncGroup(meshGroupInfo, meshMembers); + if (syncGroupResult != null && syncGroupResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh sync group success"); + } else { + System.out.println("mesh sync group failure"); + } + + //测试发送消息 + Conversation meshConversation = new Conversation(); + meshConversation.setTarget("user2"); + meshConversation.setType(ProtoConstants.ConversationType.ConversationType_Private); + MessagePayload meshPayload = new MessagePayload(); + meshPayload.setType(1); + meshPayload.setSearchableContent("mesh test message"); + IMResult meshSendMessageResult = MeshAdmin.sendMessage("user1", meshConversation, meshPayload, null); + if (meshSendMessageResult != null && meshSendMessageResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh send message success"); + } else { + System.out.println("mesh send message failure"); + } + + //测试发布消息 + if (meshSendMessageResult != null && meshSendMessageResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + SendMessageData publishMessageData = new SendMessageData(); + publishMessageData.setSender("user1"); + publishMessageData.setConv(meshConversation); + publishMessageData.setPayload(meshPayload); + IMResult publishMessageResult = MeshAdmin.publishMessage(publishMessageData, Arrays.asList("user2"), meshSendMessageResult.getResult().getMessageUid()); + if (publishMessageResult != null && publishMessageResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh publish message success"); + } else { + System.out.println("mesh publish message failure"); + } + } + + //测试添加加入群组请求 + IMResult addJoinGroupRequestResult = MeshAdmin.addJoinGroupRequest("user2", meshGroupInfo.getTarget_id(), Arrays.asList("user3"), "please add me", null); + if (addJoinGroupRequestResult != null && addJoinGroupRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh add join group request success"); + } else { + System.out.println("mesh add join group request failure"); + } + + //测试会议用户请求 + IMResult userConferenceRequestResult = MeshAdmin.userConferenceRequest("client1", "user1", "test_request", 1, "room1", "test_data", false); + if (userConferenceRequestResult != null && userConferenceRequestResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh user conference request success"); + } else { + System.out.println("mesh user conference request failure"); + } + + //测试会议用户事件 + IMResult userConferenceEventResult = MeshAdmin.userConferenceEvent("test_event_data", "user1", "client1", false); + if (userConferenceEventResult != null && userConferenceEventResult.getErrorCode() == ErrorCode.ERROR_CODE_SUCCESS) { + System.out.println("mesh user conference event success"); + } else { + System.out.println("mesh user conference event failure"); + } + + } }