lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SncpHeader优化

Browse Source
This commit is contained in:
redkale
2023-07-06 09:42:08 +08:00
parent 4c11217dda
commit a57b186c67
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/org/redkale/net/sncp/SncpHeader.java
View File

@@ -76,9 +76,9 @@ public class SncpHeader {
public static SncpHeader read(ByteBuffer buffer, final int headerSize) { public static SncpHeader read(ByteBuffer buffer, final int headerSize) {
SncpHeader header = new SncpHeader(); SncpHeader header = new SncpHeader();
header.valid = headerSize > HEADER_SUBSIZE; //2 header.valid = headerSize > HEADER_SUBSIZE; //2
header.sncpVersion = buffer.getInt(); //4
header.seqid = buffer.getLong(); //8 header.seqid = buffer.getLong(); //8
header.serviceid = Uint128.read(buffer); //16 header.serviceid = Uint128.read(buffer); //16
header.sncpVersion = buffer.getInt(); //4
header.actionid = Uint128.read(buffer); //16 header.actionid = Uint128.read(buffer); //16
if (header.addrBytes == null) { if (header.addrBytes == null) {
header.addrBytes = new byte[4]; header.addrBytes = new byte[4];
@@ -103,12 +103,12 @@ public class SncpHeader {
SncpHeader header = new SncpHeader(); SncpHeader header = new SncpHeader();
header.valid = headerSize > HEADER_SUBSIZE; //2 header.valid = headerSize > HEADER_SUBSIZE; //2
int offset = 0; int offset = 0;
header.sncpVersion = array.getInt(offset); //4
offset += 4;
header.seqid = array.getLong(offset); //8 header.seqid = array.getLong(offset); //8
offset += 8; offset += 8;
header.serviceid = array.getUint128(offset); //16 header.serviceid = array.getUint128(offset); //16
offset += 16; offset += 16;
header.sncpVersion = array.getInt(offset); //4
offset += 4;
header.actionid = array.getUint128(offset); //16 header.actionid = array.getUint128(offset); //16
offset += 16; offset += 16;
header.addrBytes = array.getBytes(offset, 4); //addr 4 header.addrBytes = array.getBytes(offset, 4); //addr 4
@@ -155,12 +155,12 @@ public class SncpHeader {
int offset = 0; int offset = 0;
array.putChar(offset, (char) size); //2 array.putChar(offset, (char) size); //2
offset += 2; offset += 2;
array.putInt(offset, sncpVersion); //4
offset += 4;
array.putLong(offset, newSeqid); //8 array.putLong(offset, newSeqid); //8
offset += 8; offset += 8;
array.putUint128(offset, serviceid); //16 array.putUint128(offset, serviceid); //16
offset += 16; offset += 16;
array.putInt(offset, sncpVersion); //4
offset += 4;
array.putUint128(offset, actionid); //16 array.putUint128(offset, actionid); //16
offset += 16; offset += 16;
array.put(offset, newAddrBytes); //4 array.put(offset, newAddrBytes); //4
@@ -201,10 +201,9 @@ public class SncpHeader {
} }
public InetSocketAddress getAddress() { public InetSocketAddress getAddress() {
if (addrBytes == null) { return addrBytes == null ? null
return null; : new InetSocketAddress((0xff & addrBytes[0]) + "." + (0xff & addrBytes[1])
} + "." + (0xff & addrBytes[2]) + "." + (0xff & addrBytes[3]), addrPort);
return new InetSocketAddress((0xff & addrBytes[0]) + "." + (0xff & addrBytes[1]) + "." + (0xff & addrBytes[2]) + "." + (0xff & addrBytes[3]), addrPort);
} }
public boolean isValid() { public boolean isValid() {