netty-修改netty版本,修改端口,此版本为二维码版本
This commit is contained in:
@@ -15,7 +15,7 @@ apply plugin: 'java'
|
|||||||
apply plugin: 'org.springframework.boot'
|
apply plugin: 'org.springframework.boot'
|
||||||
|
|
||||||
group 'SmartVenue'
|
group 'SmartVenue'
|
||||||
version '1.0-SNAPSHOT'
|
version '2.0.0'
|
||||||
|
|
||||||
sourceCompatibility = 1.8
|
sourceCompatibility = 1.8
|
||||||
|
|
||||||
|
|||||||
@@ -33,14 +33,14 @@ public class QRCodeControler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 微信小程序扫码之后,通知对应的线程进入加载界面,然后随即开始判断逻辑
|
* 检验客户端读取能力
|
||||||
* @return
|
* @return
|
||||||
*/
|
*/
|
||||||
@RequestMapping("/testChannel")
|
@RequestMapping("/checkAlive")
|
||||||
public ResponseDTO testChannel(@RequestParam String id) {
|
public ResponseDTO checkAlive(@RequestParam String id) {
|
||||||
System.out.println(ClientChannelCache.channelTypes.size());
|
System.out.println(ClientChannelCache.channelTypes.size());
|
||||||
Channel channel = ClientChannelCache.getChannelType(id);
|
Channel channel = ClientChannelCache.getChannelType(id);
|
||||||
channel.writeAndFlush("你好呀!");
|
channel.writeAndFlush("check client alive ! ");
|
||||||
return ResponseDTO.ok();
|
return ResponseDTO.ok();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -4,11 +4,9 @@ import com.sv.netty.config.Constant;
|
|||||||
import com.sv.netty.config.SpringContextHolder;
|
import com.sv.netty.config.SpringContextHolder;
|
||||||
import com.sv.netty.netty.message.ChannelParam;
|
import com.sv.netty.netty.message.ChannelParam;
|
||||||
import com.sv.netty.netty.message.HeartBeat;
|
import com.sv.netty.netty.message.HeartBeat;
|
||||||
import com.sv.netty.service.MessageService;
|
import com.sv.netty.netty.service.MessageService;
|
||||||
import com.sv.netty.utils.JsonUtils;
|
import com.sv.netty.utils.JsonUtils;
|
||||||
import io.netty.channel.*;
|
import io.netty.channel.*;
|
||||||
import io.netty.handler.timeout.IdleState;
|
|
||||||
import io.netty.handler.timeout.IdleStateEvent;
|
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
package com.sv.netty.service;
|
package com.sv.netty.netty.service;
|
||||||
|
|
||||||
import com.sv.netty.netty.message.HeartBeat;
|
import com.sv.netty.netty.message.HeartBeat;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
package com.sv.netty.service.impl;
|
package com.sv.netty.netty.service.impl;
|
||||||
|
|
||||||
import com.sv.dto.EnterResult;
|
import com.sv.dto.EnterResult;
|
||||||
import com.sv.entity.Device;
|
import com.sv.entity.Device;
|
||||||
@@ -10,9 +10,8 @@ import com.sv.netty.config.ClientChannelCache;
|
|||||||
import com.sv.netty.dto.MemberDto;
|
import com.sv.netty.dto.MemberDto;
|
||||||
import com.sv.netty.netty.message.HeartBeat;
|
import com.sv.netty.netty.message.HeartBeat;
|
||||||
import com.sv.netty.netty.message.Result;
|
import com.sv.netty.netty.message.Result;
|
||||||
import com.sv.netty.service.MessageService;
|
import com.sv.netty.netty.service.MessageService;
|
||||||
import com.sv.netty.utils.JsonMapper;
|
import com.sv.netty.utils.JsonMapper;
|
||||||
import com.sv.netty.utils.JsonUtils;
|
|
||||||
import com.sv.service.api.MemberEnterVenueLogService;
|
import com.sv.service.api.MemberEnterVenueLogService;
|
||||||
import com.sv.service.api.MemberService;
|
import com.sv.service.api.MemberService;
|
||||||
import com.sv.service.api.VenueService;
|
import com.sv.service.api.VenueService;
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
server:
|
server:
|
||||||
port: 8021
|
port: 8022
|
||||||
context-path: /netty
|
context-path: /netty
|
||||||
tomcat:
|
tomcat:
|
||||||
uri-encoding: utf-8
|
uri-encoding: utf-8
|
||||||
|
|||||||
Reference in New Issue
Block a user