| | |
|---|
| | | * @param msg |
|---|
| | | * @author TaoNingBo |
|---|
| | | */ |
|---|
| | | public void JudgeOperation(ChannelHandlerContext ctx, String msg) { |
|---|
| | | public synchronized void JudgeOperation(ChannelHandlerContext ctx, String msg) { |
|---|
| | | try { |
|---|
| | | // 验证即时通讯命令是否正确有效 |
|---|
| | | if (SinataUtil.isEmpty(msg)) { |
|---|
| | |
|---|
| | | if (StringUtil.isNotEmpty(token)) { |
|---|
| | | String token_ = redisUtil.getValue("USER_Applets_" + userId1);//获取缓存中最新的数据 |
|---|
| | | if (StringUtil.isNotEmpty(token_) && !token.equals(token_)) {//不在同一设备上登录，向其他设备发送数据 |
|---|
| | | ChannelHandlerContext data_ = NettyChannelMap.getData_(token_.substring(0, 23)); |
|---|
| | | ChannelHandlerContext data_ = NettyChannelMap.getData_(token_.substring(token_.length() - 16)); |
|---|
| | | JSONObject msg_ = new JSONObject(); |
|---|
| | | msg_.put("code", 200); |
|---|
| | | msg_.put("msg", "SUCCESS"); |
|---|
| | |
|---|
| | | } |
|---|
| | | }, 5000); |
|---|
| | | } |
|---|
| | | NettyChannelMap.update_(token.substring(0, 23), ctx);//存储单点登录的通道 |
|---|
| | | NettyChannelMap.update_(token.substring(token.length() - 16), ctx);//存储单点登录的通道 |
|---|
| | | NettyChannelMap.update("Applets" + userId1, ctx); |
|---|
| | | redisUtil.setStrValue("USER_Applets_" + userId1, token); |
|---|
| | | } |
|---|
