springboot集成swing_SpringBoot(22)集成MobileIMSDK实现即时通讯


com.google.code.gsongson2.8.5

com.zhengqingMobileIMSDK4jsystem${project.basedir}/src/main/resources/lib/MobileIMSDK4j.jar

com.zhengqingMobileIMSDKServerX_metasystem${project.basedir}/src/main/resources/lib/MobileIMSDKServerX_meta.jar

com.zhengqingswing-worker-1.2(1.6-)system${project.basedir}/src/main/resources/lib/swing-worker-1.2(1.6-).jar

com.zhengqingMobileIMSDKServerX_nettysystem${project.basedir}/src/main/resources/lib/MobileIMSDKServerX_netty.jar

org.springframework.bootspring-boot-maven-plugintrue


public class ServerEventListenerImpl implements ServerEventListener {private static Logger logger &＃61; LoggerFactory.getLogger(ServerEventListenerImpl.class);/*** 用户身份验证回调方法定义.*

* 服务端的应用层可在本方法中实现用户登陆验证。*
* 注意&＃xff1a;本回调在一种特殊情况下——即用户实际未退出登陆但再次发起来登陆包时&＃xff0c;本回调是不会被调用的&＃xff01;*

* 根据MobileIMSDK的算法实现&＃xff0c;本方法中用户验证通过&＃xff08;即方法返回值&＃61;0时&＃xff09;后* &＃xff0c;将立即调用回调方法 {&＃64;link #onUserLoginAction_CallBack(int, String, IoSession)}。* 否则会将验证结果&＃xff08;本方法返回值错误码通过客户端的 ChatBaseEvent.onLoginMessage(int dwUserId, int dwErrorCode)* 方法进行回调&＃xff09;通知客户端&＃xff09;。** &＃64;param userId 传递过来的准一id&＃xff0c;保证唯一就可以通信&＃xff0c;可能是登陆用户名、也可能是任意不重复的id等&＃xff0c;具体意义由业务层决定* &＃64;param token 用于身份鉴别和合法性检查的token&＃xff0c;它可能是登陆密码&＃xff0c;也可能是通过前置单点登陆接口拿到的token等&＃xff0c;具体意义由业务层决定* &＃64;param extra 额外信息字符串。本字段目前为保留字段&＃xff0c;供上层应用自行放置需要的内容* &＃64;param session 此客户端连接对应的 netty “会话”* &＃64;return 0 表示登陆验证通过&＃xff0c;否则可以返回用户自已定义的错误码&＃xff0c;错误码值应为&＃xff1a;>&＃61;1025的整数*/&＃64;Overridepublic int onVerifyUserCallBack(String userId, String token, String extra, Channel session) {logger.debug("【DEBUG_回调通知】正在调用回调方法&＃xff1a;OnVerifyUserCallBack...(extra&＃61;" &＃43; extra &＃43; ")");return 0;}/*** 用户登录验证成功后的回调方法定义&＃xff08;可理解为上线通知回调&＃xff09;.*

* 服务端的应用层通常可在本方法中实现用户上线通知等。*
* 注意&＃xff1a;本回调在一种特殊情况下——即用户实际未退出登陆但再次发起来登陆包时&＃xff0c;回调也是一定会被调用。** &＃64;param userId 传递过来的准一id&＃xff0c;保证唯一就可以通信&＃xff0c;可能是登陆用户名、也可能是任意不重复的id等&＃xff0c;具体意义由业务层决定* &＃64;param extra 额外信息字符串。本字段目前为保留字段&＃xff0c;供上层应用自行放置需要的内容。为了丰富应用层处理的手段&＃xff0c;在本回调中也把此字段传进来了* &＃64;param session 此客户端连接对应的 netty “会话”*/&＃64;Overridepublic void onUserLoginAction_CallBack(String userId, String extra, Channel session) {logger.debug("【IM_回调通知OnUserLoginAction_CallBack】用户&＃xff1a;" &＃43; userId &＃43; " 上线了&＃xff01;");}/*** 用户退出登录回调方法定义&＃xff08;可理解为下线通知回调&＃xff09;。*

* 服务端的应用层通常可在本方法中实现用户下线通知等。** &＃64;param userId 下线的用户user_id* &＃64;param obj* &＃64;param session 此客户端连接对应的 netty “会话”*/&＃64;Overridepublic void onUserLogoutAction_CallBack(String userId, Object obj, Channel session) {logger.debug("【DEBUG_回调通知OnUserLogoutAction_CallBack】用户&＃xff1a;" &＃43; userId &＃43; " 离线了&＃xff01;");}/*** 通用数据回调方法定义&＃xff08;客户端发给服务端的&＃xff08;即接收user_id&＃61;"0"&＃xff09;&＃xff09;.*

* MobileIMSDK在收到客户端向user_id&＃61;0(即接收目标是服务器)的情况下通过* 本方法的回调通知上层。上层通常可在本方法中实现如&＃xff1a;添加好友请求等业务实现。**

* 【版本兼容性说明】本方法用于替代v3.x中的以下方法&＃xff1a;
* public boolean onTransBuffer_CallBack(String userId, String from_user_id* , String dataContent, String fingerPrint, int typeu, Channel session);* ** &＃64;param userId 接收方的user_id&＃xff08;本方法接收的是发给服务端的消息&＃xff0c;所以此参数的值肯定&＃61;&＃61;0&＃xff09;* &＃64;param from_user_id 发送方的user_id* &＃64;param dataContent 数据内容&＃xff08;文本形式&＃xff09;* &＃64;param session 此客户端连接对应的 netty “会话”* &＃64;return true表示本方法已成功处理完成&＃xff0c;否则表示未处理成功。此返回值目前框架中并没有特殊意义&＃xff0c;仅作保留吧* &＃64;since 4.0*/&＃64;Overridepublic boolean onTransBuffer_C2S_CallBack(Protocal p, Channel session) {// 接收者uidString userId &＃61; p.getTo();// 发送者uidString from_user_id &＃61; p.getFrom();// 消息或指令内容String dataContent &＃61; p.getDataContent();// 消息或指令指纹码&＃xff08;即唯一ID&＃xff09;String fingerPrint &＃61; p.getFp();// 【重要】用户定义的消息或指令协议类型&＃xff08;开发者可据此类型来区分具体的消息或指令&＃xff09;int typeu &＃61; p.getTypeu();logger.debug("【DEBUG_回调通知】[typeu&＃61;" &＃43; typeu &＃43; "]收到了客户端" &＃43; from_user_id &＃43; "发给服务端的消息&＃xff1a;str&＃61;" &＃43; dataContent);return true;}/*** 通道数据回调函数定义&＃xff08;客户端发给客户端的&＃xff08;即接收方user_id不为“0”的情况&＃xff09;&＃xff09;.*

* 注意&＃xff1a;本方法当且仅当在数据被服务端成功在线发送出去后被回调调用.*

* 上层通常可在本方法中实现用户聊天信息的收集&＃xff0c;以便后期监控分析用户的行为等^_^。*

* 提示&＃xff1a;如果开启消息QoS保证&＃xff0c;因重传机制&＃xff0c;本回调中的消息理论上有重复的可能&＃xff0c;请以参数 #fingerPrint* 作为消息的唯一标识ID进行去重处理。**

* 【版本兼容性说明】本方法用于替代v3.x中的以下方法&＃xff1a;
* public void onTransBuffer_C2C_CallBack(String userId, String from_user_id* , String dataContent, String fingerPrint, int typeu);** &＃64;param userId 接收方的user_id&＃xff08;本方法接收的是客户端发给客户端的&＃xff0c;所以此参数的值肯定>0&＃xff09;* &＃64;param from_user_id 发送方的user_id* &＃64;param dataContent* &＃64;since 4.0*/&＃64;Overridepublic void onTransBuffer_C2C_CallBack(Protocal p) {// 接收者uidString userId &＃61; p.getTo();// 发送者uidString from_user_id &＃61; p.getFrom();// 消息或指令内容String dataContent &＃61; p.getDataContent();// 消息或指令指纹码&＃xff08;即唯一ID&＃xff09;String fingerPrint &＃61; p.getFp();// 【重要】用户定义的消息或指令协议类型&＃xff08;开发者可据此类型来区分具体的消息或指令&＃xff09;int typeu &＃61; p.getTypeu();logger.debug("【DEBUG_回调通知】[typeu&＃61;" &＃43; typeu &＃43; "]收到了客户端" &＃43; from_user_id &＃43; "发给客户端" &＃43; userId &＃43; "的消息&＃xff1a;str&＃61;" &＃43; dataContent);}/*** 通用数据实时发送失败后的回调函数定义&＃xff08;客户端发给客户端的&＃xff08;即接收方user_id不为“0”的情况&＃xff09;&＃xff09;.*

* 注意&＃xff1a;本方法当且仅当在数据被服务端在线发送失败后被回调调用.*

* 此方法存的意义何在&＃xff1f;
* 发生此种情况的场景可能是&＃xff1a;对方确实不在线&＃xff08;那么此方法里就可以作为离线消息处理了&＃xff09;、* 或者在发送时判断对方是在线的但服务端在发送时却没有成功&＃xff08;这种情况就可能是通信错误* 或对方非正常通出但尚未到达会话超时时限&＃xff09;。
应用层在此方法里实现离线消息的处理即可&＃xff01;**

* 【版本兼容性说明】本方法用于替代v3.x中的以下方法&＃xff1a;
* public boolean onTransBuffer_C2C_RealTimeSendFaild_CallBack(String userId* , String from_user_id, String dataContent, String fingerPrint, int typeu);* ** &＃64;param userId 接收方的user_id&＃xff08;本方法接收的是客户端发给客户端的&＃xff0c;所以此参数的值肯定>0&＃xff09;&＃xff0c;此id在本方法中不一定保证有意义* &＃64;param from_user_id 发送方的user_id* &＃64;param dataContent 消息内容* &＃64;param fingerPrint 该消息对应的指纹&＃xff08;如果该消息有QoS保证机制的话&＃xff09;&＃xff0c;用于在QoS重要机制下服务端离线存储时防止重复存储哦* &＃64;return true表示应用层已经处理了离线消息&＃xff08;如果该消息有QoS机制&＃xff0c;则服务端将代为发送一条伪应答包* &＃xff08;伪应答仅意味着不是接收方的实时应答&＃xff0c;而只是存储到离线DB中&＃xff0c;但在发送方看来也算是被对方收到&＃xff0c;只是延* 迟收到而已&＃xff08;离线消息嘛&＃xff09;&＃xff09;&＃xff09;&＃xff0c;否则表示应用层没有处理&＃xff08;如果此消息有QoS机制&＃xff0c;则发送方在QoS重传机制超时* 后报出消息发送失败的提示&＃xff09;* &＃64;see #onTransBuffer_C2C_CallBack(Protocal)* &＃64;since 4.0*/&＃64;Overridepublic boolean onTransBuffer_C2C_RealTimeSendFaild_CallBack(Protocal p) {// 接收者uidString userId &＃61; p.getTo();// 发送者uidString from_user_id &＃61; p.getFrom();// 消息或指令内容String dataContent &＃61; p.getDataContent();// 消息或指令指纹码&＃xff08;即唯一ID&＃xff09;String fingerPrint &＃61; p.getFp();// 【重要】用户定义的消息或指令协议类型&＃xff08;开发者可据此类型来区分具体的消息或指令&＃xff09;int typeu &＃61; p.getTypeu();logger.debug("【DEBUG_回调通知】[typeu&＃61;" &＃43; typeu &＃43; "]客户端" &＃43; from_user_id &＃43; "发给客户端" &＃43; userId &＃43; "的消息&＃xff1a;str&＃61;" &＃43; dataContent&＃43; "&＃xff0c;因实时发送没有成功&＃xff0c;需要上层应用作离线处理哦&＃xff0c;否则此消息将被丢弃.");return false;}
}

public class MessageQoSEventS2CListnerImpl implements MessageQoSEventListenerS2C {private static Logger logger &＃61; LoggerFactory.getLogger(MessageQoSEventS2CListnerImpl.class);&＃64;Overridepublic void messagesLost(ArrayList lostMessages) {logger.debug("【DEBUG_QoS_S2C事件】收到系统的未实时送达事件通知&＃xff0c;当前共有"&＃43; lostMessages.size() &＃43; "个包QoS保证机制结束&＃xff0c;判定为【无法实时送达】&＃xff01;");}&＃64;Overridepublic void messagesBeReceived(String theFingerPrint) {if (theFingerPrint !&＃61; null) {logger.debug("【DEBUG_QoS_S2C事件】收到对方已收到消息事件的通知&＃xff0c;fp&＃61;" &＃43; theFingerPrint);}}
}

public class ServerLauncherImpl extends ServerLauncher {// 静态类方法&＃xff1a;进行一些全局配置设置static {// 设置AppKey&＃xff08;此key目前为保留字段&＃xff0c;请忽略之&＃xff09;ServerLauncher.appKey &＃61; "5418023dfd98c579b6001741";// 设置MobileIMSDK服务端的网络监听端口ServerLauncherImpl.PORT &＃61; 7901;// 开/关Demog日志的输出QoS4SendDaemonS2C.getInstance().setDebugable(true);QoS4ReciveDaemonC2S.getInstance().setDebugable(true);ServerLauncher.debug &＃61; true;// TODO 与客户端协商一致的心跳敏感模式设置
// ServerToolKits.setSenseMode(SenseMode.MODE_10S);// 关闭与Web端的消息互通桥接器&＃xff08;其实SDK中默认就是false&＃xff09;ServerLauncher.bridgeEnabled &＃61; false;// TODO 跨服桥接器MQ的URI&＃xff08;本参数只在ServerLauncher.bridgeEnabled为true时有意义&＃xff09;
// BridgeProcessor.IMMQ_URI &＃61; "amqp://js:19844713&＃64;192.168.31.190";}// 实例构造方法public ServerLauncherImpl() throws IOException {super();}/*** 初始化消息处理事件监听者.*/&＃64;Overrideprotected void initListeners() {// ** 设置各种回调事件处理实现类this.setServerEventListener(new ServerEventListenerImpl());this.setServerMessageQoSEventListener(new MessageQoSEventS2CListnerImpl());}}

&＃64;Slf4j
&＃64;Component
&＃64;Order(value &＃61; 1)
public class ChatServerRunner implements CommandLineRunner {&＃64;Overridepublic void run(String... strings) throws Exception {log.info("&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61; ↓↓↓↓↓↓ 启动MobileIMSDK服务端 ↓↓↓↓↓↓ &＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;&＃61;");// 实例化后记得startup哦&＃xff0c;单独startup()的目的是让调用者可以延迟决定何时真正启动IM服务final ServerLauncherImpl sli &＃61; new ServerLauncherImpl();// 启动MobileIMSDK服务端的Demosli.startup();// 加一个钩子&＃xff0c;确保在JVM退出时释放netty的资源Runtime.getRuntime().addShutdownHook(new Thread(sli::shutdown));}}

&＃64;Slf4j
public class ChatBaseEventImpl implements ChatBaseEvent {&＃64;Overridepublic void onLoginMessage(int dwErrorCode) {if (dwErrorCode &＃61;&＃61; 0) {log.debug("IM服务器登录/连接成功&＃xff01;");} else {log.error("IM服务器登录/连接失败&＃xff0c;错误代码&＃xff1a;" &＃43; dwErrorCode);}}&＃64;Overridepublic void onLinkCloseMessage(int dwErrorCode) {log.error("与IM服务器的网络连接出错关闭了&＃xff0c;error&＃xff1a;" &＃43; dwErrorCode);}}

&＃64;Slf4j
public class ChatTransDataEventImpl implements ChatTransDataEvent {&＃64;Overridepublic void onTransBuffer(String fingerPrintOfProtocal, String userid, String dataContent, int typeu) {log.debug("[typeu&＃61;" &＃43; typeu &＃43; "]收到来自用户" &＃43; userid &＃43; "的消息:" &＃43; dataContent);}&＃64;Overridepublic void onErrorResponse(int errorCode, String errorMsg) {log.debug("收到服务端错误消息&＃xff0c;errorCode&＃61;" &＃43; errorCode &＃43; ", errorMsg&＃61;" &＃43; errorMsg);}}

&＃64;Slf4j
public class MessageQoSEventImpl implements MessageQoSEvent {&＃64;Override // 对方未成功接收消息的回调事件 lostMessages&＃xff1a;存放消息内容public void messagesLost(ArrayList lostMessages) {log.debug("收到系统的未实时送达事件通知&＃xff0c;当前共有" &＃43; lostMessages.size() &＃43; "个包QoS保证机制结束&＃xff0c;判定为【无法实时送达】&＃xff01;");}&＃64;Override // 对方成功接收到消息的回调事件public void messagesBeReceived(String theFingerPrint) {if (theFingerPrint !&＃61; null) {log.debug("收到对方已收到消息事件的通知&＃xff0c;fp&＃61;" &＃43; theFingerPrint);}}}

public class IMClientManager {private static IMClientManager instance &＃61; null;/*** MobileIMSDK是否已被初始化. true表示已初化完成&＃xff0c;否则未初始化.*/private boolean init &＃61; false;public static IMClientManager getInstance() {if (instance &＃61;&＃61; null) {instance &＃61; new IMClientManager();}return instance;}private IMClientManager() {initMobileIMSDK();}public void initMobileIMSDK() {if (!init) {// 设置AppKeyConfigEntity.appKey &＃61; "5418023dfd98c579b6001741";// 设置服务器ip和服务器端口ConfigEntity.serverIP &＃61; "127.0.0.1";ConfigEntity.serverUDPPort &＃61; 7901;// MobileIMSDK核心IM框架的敏感度模式设置
// ConfigEntity.setSenseMode(SenseMode.MODE_10S);// 开启/关闭DEBUG信息输出ClientCoreSDK.DEBUG &＃61; false;// 设置事件回调ClientCoreSDK.getInstance().setChatBaseEvent(new ChatBaseEventImpl());ClientCoreSDK.getInstance().setChatTransDataEvent(new ChatTransDataEventImpl());ClientCoreSDK.getInstance().setMessageQoSEvent(new MessageQoSEventImpl());init &＃61; true;}}}

public interface IChatService {/*** 登录连接IM服务器请求** &＃64;param username: 用户名* &＃64;param password: 密码* &＃64;return: void*/void loginConnect(String username, String password);/*** 发送消息** &＃64;param friendId: 接收消息者id* &＃64;param msg: 消息内容* &＃64;return: void*/void sendMsg(String friendId, String msg);}

&＃64;Slf4j
&＃64;Service
&＃64;Transactional(rollbackFor &＃61; Exception.class)
public class ChatServiceImpl implements IChatService {&＃64;Overridepublic void loginConnect(String username, String password) {// 确保MobileIMSDK被初始化哦&＃xff08;整个APP生生命周期中只需调用一次哦&＃xff09;// 提示&＃xff1a;在不退出APP的情况下退出登陆后再重新登陆时&＃xff0c;请确保调用本方法一次&＃xff0c;不然会报code&＃61;203错误哦&＃xff01;IMClientManager.getInstance().initMobileIMSDK();// * 异步提交登陆名和密码new LocalUDPDataSender.SendLoginDataAsync(username, password) {/*** 登陆信息发送完成后将调用本方法&＃xff08;注意&＃xff1a;此处仅是登陆信息发送完成&＃xff0c;真正的登陆结果要在异步回调中处理哦&＃xff09;。* &＃64;param code 数据发送返回码&＃xff0c;0 表示数据成功发出&＃xff0c;否则是错误码*/protected void fireAfterSendLogin(int code) {if (code &＃61;&＃61; 0) {log.debug("数据发送成功&＃xff01;");} else {log.error("数据发送失败。错误码是&＃xff1a;" &＃43; code);}}}.execute();}&＃64;Overridepublic void sendMsg(String friendId, String msg) {// 发送消息&＃xff08;异步提升体验&＃xff0c;你也可直接调用LocalUDPDataSender.send(..)方法发送&＃xff09;new LocalUDPDataSender.SendCommonDataAsync(msg, friendId) {&＃64;Overrideprotected void onPostExecute(Integer code) {if (code &＃61;&＃61; 0) {log.debug("数据已成功发出&＃xff01;");} else {log.error("数据发送失败。错误码是&＃xff1a;" &＃43; code &＃43; "&＃xff01;");}}}.execute();}}

&＃64;RestController
&＃64;RequestMapping("/api")
&＃64;Api(tags &＃61; "聊天测试-接口")
public class ChatController {&＃64;Autowiredprivate IChatService chatService;&＃64;PostMapping(value &＃61; "/loginConnect", produces &＃61; Constants.CONTENT_TYPE)&＃64;ApiOperation(value &＃61; "登陆请求", httpMethod &＃61; "POST", response &＃61; ApiResult.class)public ApiResult loginConnect(&＃64;RequestParam String username, &＃64;RequestParam String password) {chatService.loginConnect(username, password);return ApiResult.ok();}&＃64;PostMapping(value &＃61; "/sendMsg", produces &＃61; Constants.CONTENT_TYPE)&＃64;ApiOperation(value &＃61; "发送消息", httpMethod &＃61; "POST", response &＃61; ApiResult.class)public ApiResult sendMsg(&＃64;RequestParam String friendId, &＃64;RequestParam String msg) {chatService.sendMsg(friendId, msg);return ApiResult.ok();}}