autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-06-11 10:49:52 +08:00
Code Issues Packages Projects Releases Wiki Activity

update 电单车协议

Browse Source
This commit is contained in:
Guoqs
2024-07-15 11:33:11 +08:00
parent 450d6799a6
commit 2186b3e857
8 changed files with 192 additions and 69 deletions
Download Patch File Download Diff File Expand all files Collapse all files

140
jsowell-netty/src/main/java/com/jsowell/netty/decoder/StartAndLengthFieldFrameDecoder.java
View File

@@ -14,11 +14,11 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
private static final int HEADER_LENGTH_68 = 1; // 68 包头的长度 private static final int HEADER_LENGTH_68 = 1; // 68 包头的长度
// 起始标志 // 起始标志
private int HEAD_DATA; // private int HEAD_DATA;
public StartAndLengthFieldFrameDecoder(int HEAD_DATA) { // public StartAndLengthFieldFrameDecoder(int HEAD_DATA) {
this.HEAD_DATA = HEAD_DATA; // this.HEAD_DATA = HEAD_DATA;
} // }
/** /**
* <pre> * <pre>
@@ -26,62 +26,62 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
* 表示数据的长度contentLength，int类型，占据1个字节. * 表示数据的长度contentLength，int类型，占据1个字节.
* </pre> * </pre>
*/ */
public final int BASE_LENGTH = 1 + 1; // public final int BASE_LENGTH = 1 + 1;
// @Override // @Override
protected void decode2(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception { // protected void decode2(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception {
// 可读长度必须大于基本长度 // // 可读长度必须大于基本长度
if (buffer.readableBytes() <= BASE_LENGTH) { // if (buffer.readableBytes() <= BASE_LENGTH) {
log.warn("可读字节数:{}小于基础长度:{}", buffer.readableBytes(), BASE_LENGTH); // log.warn("可读字节数:{}小于基础长度:{}", buffer.readableBytes(), BASE_LENGTH);
return; // return;
} // }
//
// 记录包头开始的index // // 记录包头开始的index
int beginReader; // int beginReader;
//
while (true) { // while (true) {
// 获取包头开始的index // // 获取包头开始的index
beginReader = buffer.readerIndex(); // beginReader = buffer.readerIndex();
// log.info("包头开始的index:{}", beginReader); // // log.info("包头开始的index:{}", beginReader);
// 标记包头开始的index // // 标记包头开始的index
buffer.markReaderIndex(); // buffer.markReaderIndex();
// 读到了协议的开始标志，结束while循环 // // 读到了协议的开始标志，结束while循环
if (buffer.getUnsignedByte(beginReader) == HEAD_DATA) { // if (buffer.getUnsignedByte(beginReader) == HEAD_DATA) {
// log.info("读到了协议的开始标志，结束while循环 byte:{}, HEAD_DATA:{}", buffer.getUnsignedByte(beginReader), HEAD_DATA); // // log.info("读到了协议的开始标志，结束while循环 byte:{}, HEAD_DATA:{}", buffer.getUnsignedByte(beginReader), HEAD_DATA);
break; // break;
} // }
//
// 未读到包头，略过一个字节 // // 未读到包头，略过一个字节
// 每次略过，一个字节，去读取，包头信息的开始标记 // // 每次略过，一个字节，去读取，包头信息的开始标记
buffer.resetReaderIndex(); // buffer.resetReaderIndex();
buffer.readByte(); // buffer.readByte();
//
// 当略过，一个字节之后， // // 当略过，一个字节之后，
// 数据包的长度，又变得不满足 // // 数据包的长度，又变得不满足
// 此时，应该结束。等待后面的数据到达 // // 此时，应该结束。等待后面的数据到达
if (buffer.readableBytes() < BASE_LENGTH) { // if (buffer.readableBytes() < BASE_LENGTH) {
log.debug("数据包的长度不满足 readableBytes:{}, BASE_LENGTH:{}", buffer.readableBytes(), BASE_LENGTH); // log.debug("数据包的长度不满足 readableBytes:{}, BASE_LENGTH:{}", buffer.readableBytes(), BASE_LENGTH);
return; // return;
} // }
} // }
//
// 消息的长度 // // 消息的长度
int length = buffer.getUnsignedByte(beginReader + 1); // int length = buffer.getUnsignedByte(beginReader + 1);
// 判断请求数据包数据是否到齐 // // 判断请求数据包数据是否到齐
if (buffer.readableBytes() < length + 4) { // if (buffer.readableBytes() < length + 4) {
// log.info("请求数据包数据没有到齐,还原读指针 readableBytes:{}, 消息的长度:{}", buffer.readableBytes(), length); // // log.info("请求数据包数据没有到齐,还原读指针 readableBytes:{}, 消息的长度:{}", buffer.readableBytes(), length);
// 还原读指针 // // 还原读指针
buffer.readerIndex(beginReader); // buffer.readerIndex(beginReader);
return; // return;
} // }
//
// 读取data数据 // // 读取data数据
byte[] data = new byte[length + 4]; // byte[] data = new byte[length + 4];
buffer.readBytes(data); // buffer.readBytes(data);
ByteBuf frame = buffer.retainedSlice(beginReader, length + 4); // ByteBuf frame = buffer.retainedSlice(beginReader, length + 4);
buffer.readerIndex(beginReader + length + 4); // buffer.readerIndex(beginReader + length + 4);
out.add(frame); // out.add(frame);
} // }
protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception { protected void decode(ChannelHandlerContext ctx, ByteBuf buffer, List<Object> out) throws Exception {
// 记录包头开始的index // 记录包头开始的index
@@ -97,7 +97,12 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
buffer.markReaderIndex(); buffer.markReaderIndex();
// 读到了协议的开始标志，结束while循环 // 读到了协议的开始标志，结束while循环
if (buffer.getUnsignedByte(beginReader) == HEAD_DATA) { // if (buffer.getUnsignedByte(beginReader) == HEAD_DATA) {
// break;
// }
// 读到了协议的开始标志，结束while循环
if (isStartOfDnyHeader(buffer, beginReader) || isStartOf68Header(buffer, beginReader)) {
break; break;
} }
@@ -132,6 +137,23 @@ public class StartAndLengthFieldFrameDecoder extends ByteToMessageDecoder {
buffer.resetReaderIndex(); buffer.resetReaderIndex();
} }
private boolean isStartOfDnyHeader(ByteBuf buffer, int beginReader) {
if (buffer.readableBytes() >= HEADER_LENGTH_DNY) {
byte[] headerBytes = new byte[HEADER_LENGTH_DNY];
buffer.getBytes(beginReader, headerBytes, 0, HEADER_LENGTH_DNY);
String header = new String(headerBytes, StandardCharsets.UTF_8);
return "DNY".equals(header);
}
return false;
}
private boolean isStartOf68Header(ByteBuf buffer, int beginReader) {
if (buffer.readableBytes() >= HEADER_LENGTH_68) {
return buffer.getUnsignedByte(beginReader) == 0x68;
}
return false;
}
private void decode68Message(ByteBuf buffer, List<Object> out, int beginReader) { private void decode68Message(ByteBuf buffer, List<Object> out, int beginReader) {
if (buffer.readableBytes() < HEADER_LENGTH_68 + 1) { if (buffer.readableBytes() < HEADER_LENGTH_68 + 1) {
buffer.readerIndex(beginReader); buffer.readerIndex(beginReader);

98
jsowell-netty/src/main/java/com/jsowell/netty/server/NettyServerManager.java Normal file
View File

@@ -0,0 +1,98 @@
package com.jsowell.netty.server;
import com.jsowell.common.constant.Constants;
import com.jsowell.netty.server.yunkuaichong.NettyServerChannelInitializer;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.net.InetSocketAddress;
@Slf4j
@Component
public class NettyServerManager implements CommandLineRunner {
@Resource
private NettyServerChannelInitializer nettyServerChannelInitializer;
@Override
public void run(String... args) throws Exception {
startNettyServer(Constants.SOCKET_IP, 9011);
startElectricBikeNettyServer(Constants.SOCKET_IP, 9012);
}
public void startNettyServer(String host, int port) {
new Thread(() -> {
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap()
.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.handler(new LoggingHandler(LogLevel.DEBUG))
.option(ChannelOption.SO_BACKLOG, 128)
.option(ChannelOption.SO_REUSEADDR, true)
.childOption(ChannelOption.SO_KEEPALIVE, true)
.childOption(ChannelOption.SO_REUSEADDR, true)
.childHandler(nettyServerChannelInitializer)
.localAddress(new InetSocketAddress(host, port));
ChannelFuture future = bootstrap.bind(port).sync();
if (future.isSuccess()) {
log.info("NettyServer启动成功, 开始监听端口:{}", port);
} else {
log.error("NettyServer启动失败", future.cause());
}
future.channel().closeFuture().sync();
} catch (Exception e) {
log.error("NettyServer.start error", e);
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}).start();
}
public void startElectricBikeNettyServer(String host, int port) {
new Thread(() -> {
EventLoopGroup bossGroup = new NioEventLoopGroup(1);
EventLoopGroup workerGroup = new NioEventLoopGroup();
try {
ServerBootstrap bootstrap = new ServerBootstrap()
.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.handler(new LoggingHandler(LogLevel.DEBUG))
.option(ChannelOption.SO_BACKLOG, 128)
.option(ChannelOption.SO_REUSEADDR, true)
.childOption(ChannelOption.SO_KEEPALIVE, true)
.childOption(ChannelOption.SO_REUSEADDR, true)
.childHandler(nettyServerChannelInitializer)
.localAddress(new InetSocketAddress(host, port));
ChannelFuture future = bootstrap.bind(port).sync();
if (future.isSuccess()) {
log.info("ElectricBikeNettyServer启动成功, 开始监听端口:{}", port);
} else {
log.error("ElectricBikeNettyServer启动失败", future.cause());
}
future.channel().closeFuture().sync();
} catch (Exception e) {
log.error("ElectricBikeNettyServer.start error", e);
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}).start();
}
}

2
jsowell-netty/src/main/java/com/jsowell/netty/server/mqtt/MqttSever.java
View File

@@ -20,7 +20,7 @@ import java.net.InetSocketAddress;
@Slf4j @Slf4j
@Component @Component
@Order(5) @Order(7)
public class MqttSever implements CommandLineRunner { public class MqttSever implements CommandLineRunner {
@Override @Override

5
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServer.java
View File

@@ -16,8 +16,9 @@ import javax.annotation.Resource;
import java.net.InetSocketAddress; import java.net.InetSocketAddress;
@Slf4j @Slf4j
@Component @Deprecated
@Order(2) // @Component
// @Order(3)
public class NettyServer implements CommandLineRunner { public class NettyServer implements CommandLineRunner {
@Resource @Resource
private NettyServerChannelInitializer nettyServerChannelInitializer; private NettyServerChannelInitializer nettyServerChannelInitializer;

2
jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServerChannelInitializer.java
View File

@@ -21,7 +21,7 @@ public class NettyServerChannelInitializer extends ChannelInitializer<SocketChan
protected void initChannel(SocketChannel channel) throws Exception { protected void initChannel(SocketChannel channel) throws Exception {
ChannelPipeline pipeline = channel.pipeline(); ChannelPipeline pipeline = channel.pipeline();
// pipeline.addLast("frameDecoder",new CustomDecoder()); // pipeline.addLast("frameDecoder",new CustomDecoder());
pipeline.addLast("frameDecoder", new StartAndLengthFieldFrameDecoder(0x68)); pipeline.addLast("frameDecoder", new StartAndLengthFieldFrameDecoder());
pipeline.addLast("decoder", new ByteArrayDecoder()); pipeline.addLast("decoder", new ByteArrayDecoder());
pipeline.addLast("encoder", new ByteArrayDecoder()); pipeline.addLast("encoder", new ByteArrayDecoder());
//读超时时间设置为10s，0表示不监控 //读超时时间设置为10s，0表示不监控

4
jsowell-pile/src/main/java/com/jsowell/adapay/config/InitializeAdapayConfig.java
View File

@@ -16,7 +16,7 @@ import java.util.Map;
@Slf4j @Slf4j
@Component @Component
@Order(1) @Order(2)
public class InitializeAdapayConfig implements CommandLineRunner { public class InitializeAdapayConfig implements CommandLineRunner {
@Value("${adapay.debugFlag}") @Value("${adapay.debugFlag}")
@@ -36,7 +36,6 @@ public class InitializeAdapayConfig implements CommandLineRunner {
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
log.info(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 InitializeAdapayConfig order 1 <<<<<<<<<<<<<");
/* /*
单商户 单商户
*/ */
@@ -47,6 +46,7 @@ public class InitializeAdapayConfig implements CommandLineRunner {
目前有jsowell和xixiao 目前有jsowell和xixiao
*/ */
multiMerchant(); multiMerchant();
log.info(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 InitializeAdapayConfig order 2 <<<<<<<<<<<<<");
} }
/** /**

4
jsowell-pile/src/main/java/com/jsowell/alipay/config/AliPayConfig.java
View File

@@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
@Slf4j @Slf4j
@Component @Component
@Order(2) @Order(4)
public class AliPayConfig implements CommandLineRunner { public class AliPayConfig implements CommandLineRunner {
@Value("${alipay.gatewayHost}") @Value("${alipay.gatewayHost}")
private String gatewayHost; private String gatewayHost;
@@ -33,7 +33,6 @@ public class AliPayConfig implements CommandLineRunner {
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
log.info(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 AliPayConfig order 2 <<<<<<<<<<<<<");
// 设置参数（全局只需设置一次） // 设置参数（全局只需设置一次）
Config config = new Config(); Config config = new Config();
config.protocol = Constants.HTTPS; config.protocol = Constants.HTTPS;
@@ -57,5 +56,6 @@ public class AliPayConfig implements CommandLineRunner {
// 可设置AES密钥，调用AES加解密相关接口时需要（可选） // 可设置AES密钥，调用AES加解密相关接口时需要（可选）
config.encryptKey = encryptKey; config.encryptKey = encryptKey;
Factory.setOptions(config); Factory.setOptions(config);
log.info(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 AliPayConfig order 4 <<<<<<<<<<<<<");
} }
} }

6
jsowell-pile/src/main/java/com/jsowell/wxpay/config/WechatPayConfig.java
View File

@@ -3,13 +3,15 @@ package com.jsowell.wxpay.config;
import com.jsowell.wxpay.common.WeChatPayParameter; import com.jsowell.wxpay.common.WeChatPayParameter;
import com.jsowell.wxpay.utils.WechatPayUtils; import com.jsowell.wxpay.utils.WechatPayUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.CommandLineRunner; import org.springframework.boot.CommandLineRunner;
import org.springframework.core.annotation.Order; import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@Order(3) @Slf4j
@Component @Component
@Order(5)
public class WechatPayConfig implements CommandLineRunner { public class WechatPayConfig implements CommandLineRunner {
/** /**
* 公众号appid * 公众号appid
@@ -78,7 +80,6 @@ public class WechatPayConfig implements CommandLineRunner {
@Override @Override
public void run(String... args) throws Exception { public void run(String... args) throws Exception {
System.out.println(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 WechatPayConfig order 3 <<<<<<<<<<<<<");
//微信支付 //微信支付
WeChatPayParameter.mchId = wechatMchId; WeChatPayParameter.mchId = wechatMchId;
WeChatPayParameter.appId = wechatAppId; WeChatPayParameter.appId = wechatAppId;
@@ -94,5 +95,6 @@ public class WechatPayConfig implements CommandLineRunner {
WeChatPayParameter.mchSerialNo = mchSerialNo; WeChatPayParameter.mchSerialNo = mchSerialNo;
//获取平台证书 //获取平台证书
WeChatPayParameter.certificateMap = WechatPayUtils.refreshCertificate(); WeChatPayParameter.certificateMap = WechatPayUtils.refreshCertificate();
log.info(">>>>>>>>>>>>>>>服务启动执行，执行加载数据等操作 WechatPayConfig order 5 <<<<<<<<<<<<<");
} }
} }