NativeWebSocket
NativeWebSocket copied to clipboard
endel
Client connection closes automatically after a while
On Unity Editor the connection automatic closed after a period of not receiving or sending messages My server has packets sent in a certain order. If the wrong packet is sent, the connection will be disconnected. I wonder if nativesocket will automatically send anything? Thanks for your works nativesocket very useful :3
using System;
public class MessageReceiving { private int lengData; private int currentReader;
public short cmd;
private byte[] buffer;
private bool isMessageCorrect;
public long timeProcess;
public MessageReceiving(byte[] DATA) {
int ch1 = DATA[0] & 0xFF;
int ch2 = DATA[1] & 0xFF;
cmd=(short)((ch1 << 8) | (ch2 << 0));
lengData=DATA.Length;
currentReader=2;
buffer=DATA;
isMessageCorrect=true;
}
public short getCMD() {return cmd;}
//public string getCMDName(){return CMD_REALTIME.getCMDName(cmd);}
public int avaiable() {return lengData-currentReader;}
public void moveToEnd(){currentReader=lengData;}
public byte[] getEndByte() {
int lengClone=lengData-currentReader;
byte[] data=new byte[lengClone];
for(int i=0;i<lengClone;i++)
data[i]=buffer[i+currentReader];
return data;
}
public bool validate() {return isMessageCorrect && (lengData-currentReader)==0;}
public bool isCorrect() {return isMessageCorrect;}
public bool isRelease() {return lengData-currentReader==0;}
public int lengthReceive() { return lengData; }
public void skip(int numberArray){
if(currentReader+numberArray>lengData){
isMessageCorrect=false;
}else
currentReader+=numberArray;
}
public bool readBoolean() {
if(currentReader<lengData){
bool result=buffer[currentReader]!=0;
currentReader++;
return result;
}else{
isMessageCorrect=false;
return false;
}
}
public sbyte readByte() {
if(currentReader<lengData){
sbyte result= (sbyte)buffer[currentReader];
currentReader++;
return result;
}else{
isMessageCorrect=false;
return 0;
}
}
public short readShort() {
if(currentReader+1<lengData){
int ch1 = buffer[currentReader] & 0xFF;
int ch2 = buffer[currentReader+1] & 0xFF;
currentReader=currentReader+2;
return (short)((ch1 << 8) + (ch2 << 0));
}else{
isMessageCorrect=false;
return 0;
}
}
public int readInt() {
if(currentReader+3<lengData){
int ch1 = buffer[currentReader] & 0xFF;
int ch2 = buffer[currentReader+1] & 0xFF;
int ch3 = buffer[currentReader+2] & 0xFF;
int ch4 = buffer[currentReader+3] & 0xFF;
currentReader=currentReader+4;
return ((ch1 << 24) + (ch2 << 16) + (ch3 << 8) + (ch4 << 0));
}else{
isMessageCorrect=false;
return 0;
}
}
public long readLong() {
if(currentReader+7<lengData){
long l0 = buffer[currentReader] & 0xFF;
long l1 = buffer[currentReader+1] & 0xFF;
long l2 = buffer[currentReader+2] & 0xFF;
long l3 = buffer[currentReader+3] & 0xFF;
long l4 = buffer[currentReader+4] & 0xFF;
long l5 = buffer[currentReader+5] & 0xFF;
long l6 = buffer[currentReader+6] & 0xFF;
long l7 = buffer[currentReader+7] & 0xFF;
long r0 = l0 << 56;
long r1 = l1 << 48;
long r2 = l2 << 40;
long r3 = l3 << 32;
long r4 = l4 << 24;
long r5 = l5 << 16;
long r6 = l6 << 8;
long r7 = l7;
currentReader=currentReader+8;
return r0 + r1 + r2 + r3 + r4 + r5 + r6 + r7;
}else{
isMessageCorrect=false;
return 0;
}
}
public float readFloatFromInt() {return ((float)readInt())/1000;}
public double readDoubleFromLong() {return ((double)readLong())/1000000;}
public sbyte[] readMiniByte(){
sbyte lengthReceive = readByte();
if (lengthReceive < 1)
return null;
sbyte[] dataReceive = new sbyte[lengthReceive];
for (sbyte i = 0; i < lengthReceive; i++)
dataReceive[i] = readByte();
return dataReceive;
}
public String readString(){
if(lengData-currentReader<2){
isMessageCorrect=false;
return "";
}
int utflen = (((buffer[currentReader] & 0xff) << 8) | (buffer[currentReader+1] & 0xff));
if(lengData-currentReader<utflen+2){
isMessageCorrect=false;
return "";
}
byte[] bytearr = null;
char[] chararr = null;
// if(data.length<utflen){ bytearr = new byte[utflen2]; chararr = new char[utflen2]; // }
int c, char2, char3;
int count = 0;
int chararr_count=0;
for(int i=0;i<utflen;i++)
bytearr[i]=buffer[i+currentReader+2];
currentReader=currentReader+utflen+2;
while (count < utflen) {
c = (int) bytearr[count] & 0xff;
if (c > 127) break;
count++;
chararr[chararr_count++]=(char)c;
}
while (count < utflen) {
c = (int) bytearr[count] & 0xff;
switch (c >> 4) {
case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7:
/* 0xxxxxxx*/
count++;
chararr[chararr_count++]=(char)c;
break;
case 12: case 13:
/* 110x xxxx 10xx xxxx*/
count += 2;
if (count > utflen){
// throw new UTFDataFormatException("malformed input: partial character at end"); return ""; } char2 = (int) bytearr[count-1]; if ((char2 & 0xC0) != 0x80){ // throw new UTFDataFormatException("malformed input around byte " + count); return ""; } chararr[chararr_count++]=(char)(((c & 0x1F) << 6) | (char2 & 0x3F)); break; case 14: /* 1110 xxxx 10xx xxxx 10xx xxxx / count += 3; if (count > utflen){ // throw new UTFDataFormatException("malformed input: partial character at end"); return ""; } char2 = (int) bytearr[count-2]; char3 = (int) bytearr[count-1]; if (((char2 & 0xC0) != 0x80) || ((char3 & 0xC0) != 0x80)){ // throw new UTFDataFormatException("malformed input around byte " + (count-1)); return ""; } chararr[chararr_count++]=(char)(((c & 0x0F) << 12) | ((char2 & 0x3F) << 6) | ((char3 & 0x3F) << 0)); break; default: / 10xx xxxx, 1111 xxxx */ // throw new UTFDataFormatException("malformed input around byte " + count); return ""; } } // The number of chars produced may be less than utflen return new String(chararr, 0, chararr_count); } }
using System;
public class MessageReceiving { private int lengData; private int currentReader;
public short cmd;
private byte[] buffer;
private bool isMessageCorrect;
public long timeProcess;
public MessageReceiving(byte[] DATA) {
int ch1 = DATA[0] & 0xFF;
int ch2 = DATA[1] & 0xFF;
cmd=(short)((ch1 << 8) | (ch2 << 0));
lengData=DATA.Length;
currentReader=2;
buffer=DATA;
isMessageCorrect=true;
}
public short getCMD() {return cmd;}
//public string getCMDName(){return CMD_REALTIME.getCMDName(cmd);}
public int avaiable() {return lengData-currentReader;}
public void moveToEnd(){currentReader=lengData;}
public byte[] getEndByte() {
int lengClone=lengData-currentReader;
byte[] data=new byte[lengClone];
for(int i=0;i<lengClone;i++)
data[i]=buffer[i+currentReader];
return data;
}
public bool validate() {return isMessageCorrect && (lengData-currentReader)==0;}
public bool isCorrect() {return isMessageCorrect;}
public bool isRelease() {return lengData-currentReader==0;}
public int lengthReceive() { return lengData; }
public void skip(int numberArray){
if(currentReader+numberArray>lengData){
isMessageCorrect=false;
}else
currentReader+=numberArray;
}
public bool readBoolean() {
if(currentReader<lengData){
bool result=buffer[currentReader]!=0;
currentReader++;
return result;
}else{
isMessageCorrect=false;
return false;
}
}
public sbyte readByte() {
if(currentReader<lengData){
sbyte result= (sbyte)buffer[currentReader];
currentReader++;
return result;
}else{
isMessageCorrect=false;
return 0;
}
}
public short readShort() {
if(currentReader+1<lengData){
int ch1 = buffer[currentReader] & 0xFF;
int ch2 = buffer[currentReader+1] & 0xFF;
currentReader=currentReader+2;
return (short)((ch1 << 8) + (ch2 << 0));
}else{
isMessageCorrect=false;
return 0;
}
}
public int readInt() {
if(currentReader+3<lengData){
int ch1 = buffer[currentReader] & 0xFF;
int ch2 = buffer[currentReader+1] & 0xFF;
int ch3 = buffer[currentReader+2] & 0xFF;
int ch4 = buffer[currentReader+3] & 0xFF;
currentReader=currentReader+4;
return ((ch1 << 24) + (ch2 << 16) + (ch3 << 8) + (ch4 << 0));
}else{
isMessageCorrect=false;
return 0;
}
}
public long readLong() {
if(currentReader+7<lengData){
long l0 = buffer[currentReader] & 0xFF;
long l1 = buffer[currentReader+1] & 0xFF;
long l2 = buffer[currentReader+2] & 0xFF;
long l3 = buffer[currentReader+3] & 0xFF;
long l4 = buffer[currentReader+4] & 0xFF;
long l5 = buffer[currentReader+5] & 0xFF;
long l6 = buffer[currentReader+6] & 0xFF;
long l7 = buffer[currentReader+7] & 0xFF;
long r0 = l0 << 56;
long r1 = l1 << 48;
long r2 = l2 << 40;
long r3 = l3 << 32;
long r4 = l4 << 24;
long r5 = l5 << 16;
long r6 = l6 << 8;
long r7 = l7;
currentReader=currentReader+8;
return r0 + r1 + r2 + r3 + r4 + r5 + r6 + r7;
}else{
isMessageCorrect=false;
return 0;
}
}
public float readFloatFromInt() {return ((float)readInt())/1000;}
public double readDoubleFromLong() {return ((double)readLong())/1000000;}
public sbyte[] readMiniByte(){
sbyte lengthReceive = readByte();
if (lengthReceive < 1)
return null;
sbyte[] dataReceive = new sbyte[lengthReceive];
for (sbyte i = 0; i < lengthReceive; i++)
dataReceive[i] = readByte();
return dataReceive;
}
public String readString(){
if(lengData-currentReader<2){
isMessageCorrect=false;
return "";
}
int utflen = (((buffer[currentReader] & 0xff) << 8) | (buffer[currentReader+1] & 0xff));
if(lengData-currentReader<utflen+2){
isMessageCorrect=false;
return "";
}
byte[] bytearr = null;
char[] chararr = null;
// if(data.length<utflen){ bytearr = new byte[utflen2]; chararr = new char[utflen2]; // }
int c, char2, char3;
int count = 0;
int chararr_count=0;
for(int i=0;i<utflen;i++)
bytearr[i]=buffer[i+currentReader+2];
currentReader=currentReader+utflen+2;
while (count < utflen) {
c = (int) bytearr[count] & 0xff;
if (c > 127) break;
count++;
chararr[chararr_count++]=(char)c;
}
while (count < utflen) {
c = (int) bytearr[count] & 0xff;
switch (c >> 4) {
case 0: case 1: case 2: case 3: case 4: case 5: case 6: case 7:
/* 0xxxxxxx*/
count++;
chararr[chararr_count++]=(char)c;
break;
case 12: case 13:
/* 110x xxxx 10xx xxxx*/
count += 2;
if (count > utflen){
// throw new UTFDataFormatException("malformed input: partial character at end"); return ""; } char2 = (int) bytearr[count-1]; if ((char2 & 0xC0) != 0x80){ // throw new UTFDataFormatException("malformed input around byte " + count); return ""; } chararr[chararr_count++]=(char)(((c & 0x1F) << 6) | (char2 & 0x3F)); break; case 14: /* 1110 xxxx 10xx xxxx 10xx xxxx / count += 3; if (count > utflen){ // throw new UTFDataFormatException("malformed input: partial character at end"); return ""; } char2 = (int) bytearr[count-2]; char3 = (int) bytearr[count-1]; if (((char2 & 0xC0) != 0x80) || ((char3 & 0xC0) != 0x80)){ // throw new UTFDataFormatException("malformed input around byte " + (count-1)); return ""; } chararr[chararr_count++]=(char)(((c & 0x0F) << 12) | ((char2 & 0x3F) << 6) | ((char3 & 0x3F) << 0)); break; default: / 10xx xxxx, 1111 xxxx */ // throw new UTFDataFormatException("malformed input around byte " + count); return ""; } } // The number of chars produced may be less than utflen return new String(chararr, 0, chararr_count); } }
using System;
public class MessageSending { public int timeWithNetwork; private short cmd; private byte[] data; public MessageSending(short CMD) { cmd=CMD; data = new byte[2]; data[0] = (byte)((int)((uint)CMD >> 8) & 0xFF); data[1] = (byte)((int)((uint)CMD >> 0) & 0xFF); }
public void ClearData(){
data = new byte[2];
data[0] = (byte)((int)((uint)cmd >> 8) & 0xFF);
data[1] = (byte)((int)((uint)cmd >> 0) & 0xFF);
}
public int avaiable() {return data.Length;}
public short getCMD() {return cmd;}
public void writeBoolean(bool value) {
int length=data.Length;
byte[] temp=new byte[length+1];
for(int i=0;i<length;i++)
temp[i]=data[i];
if(value)
temp[length]=1;
else
temp[length]=0;
data=temp;
}
public void writeByte(sbyte value) {
writeByte((byte)value);
}
public void writeByte(byte value) {
int length=data.Length;
byte[] temp=new byte[length+1];
for(int i=0;i<length;i++)
temp[i]=data[i];
temp[length]=value;
data=temp;
}
public void writeByteArray(byte[] arr) {
int l=data.Length;
byte[] temp;
if(arr==null){
temp=new byte[l+4];
for(int i=0;i<l;i++)
temp[i]=data[i];
}else{
int larr=arr.Length;
temp=new byte[l+4+larr];
for(int i=0;i<l;i++)
temp[i]=data[i];
for(int i=0;i<larr;i++)
temp[l+4+i]=arr[i];
temp[l] =(byte)((int)((uint)larr >> 24) & 0xFF);
temp[l+1]=(byte)((int)((uint)larr >> 16) & 0xFF);
temp[l+2]=(byte)((int)((uint)larr >> 8) & 0xFF);
temp[l+3]=(byte)((int)((uint)larr >> 0) & 0xFF);
}
data=temp;
}
public void writeshort(short paramInt) {
int length=data.Length;
byte[] temp=new byte[length+2];
for(int i=0;i<length;i++)
temp[i]=data[i];
temp[length] = (byte) ((int)((uint)paramInt >> 8) & 0xFF);
temp[length+1] = (byte) ((int)((uint)paramInt >> 0) & 0xFF);
data=temp;
}
public void writeInt(int paramInt) {
int length=data.Length;
byte[] temp=new byte[length+4];
for(int i=0;i<length;i++)
temp[i]=data[i];
temp[length] =(byte)((int)((uint)paramInt >> 24) & 0xFF);
temp[length+1]=(byte)((int)((uint)paramInt >> 16) & 0xFF);
temp[length+2]=(byte)((int)((uint)paramInt >> 8) & 0xFF);
temp[length+3]=(byte)((int)((uint)paramInt >> 0) & 0xFF);
data=temp;
}
public void writeLong(long paramLong) {
int length=data.Length;
byte[] temp=new byte[length+8];
for(int i=0;i<length;i++)
temp[i]=data[i];
temp[length] = (byte)((ulong)paramLong >> 56);
temp[length+1] = (byte)((ulong)paramLong >> 48);
temp[length+2] = (byte)((ulong)paramLong >> 40);
temp[length+3] = (byte)((ulong)paramLong >> 32);
temp[length+4] = (byte)((ulong)paramLong >> 24);
temp[length+5] = (byte)((ulong)paramLong >> 16);
temp[length+6] = (byte)((ulong)paramLong >> 8);
temp[length+7] = (byte)((ulong)paramLong >> 0);
data=temp;
}
public void writeCopyData(byte[] copyData) {
if(copyData==null)
return;
int lengthCopy=copyData.Length;
if(lengthCopy==0)
return;
int currentLength=data.Length;
byte[] temp=new byte[currentLength+lengthCopy];
for(int i=0;i<currentLength;i++)
temp[i]=data[i];
for(int i=0;i<lengthCopy;i++)
temp[i+currentLength]=copyData[i];
data=temp;
}
public void writeFloatFromInt(float n) {writeInt((int) (n*1000));}
public void writeDoubleFromLong(double n) {writeLong((long) (n*1000000));}
public int writeString(String value) {
if(value==null)
value="";
int stringLenth = value.Length;
int j = 0;
int k;
for (int n = 0; n < stringLenth; n++) {
k = value[n];
if ((k >= 1) && (k <= 127)) {
j++;
} else if (k > 2047) {
j += 3;
} else {
j += 2;
}
}
// if (j > 65535) { // throw new UTFDataFormatException("encoded string too long: " + j + " bytes"); // } byte[] arrayOfString = new byte[j * 2 + 2]; arrayOfString[0] = (byte)((int)((uint)j >> 8) & 0xFF); arrayOfString[1] = (byte)((int)((uint)j >> 0) & 0xFF);
int count=2;
int i1 = 0;
for (i1 = 0; i1 < stringLenth; i1++) {
k = value[i1];
if ((k < 1) || (k > 127)) {
break;
}
arrayOfString[(count++)] = ((byte) k);
}
while (i1 < stringLenth) {
k = value[i1];
if ((k >= 1) && (k <= 127)) {
arrayOfString[(count++)] = ((byte) k);
} else if (k > 2047) {
arrayOfString[(count++)] = ((byte) (0xE0 | k >> 12 & 0xF));
arrayOfString[(count++)] = ((byte) (0x80 | k >> 6 & 0x3F));
arrayOfString[(count++)] = ((byte) (0x80 | k >> 0 & 0x3F));
} else {
arrayOfString[(count++)] = ((byte) (0xC0 | k >> 6 & 0x1F));
arrayOfString[(count++)] = ((byte) (0x80 | k >> 0 & 0x3F));
}
i1++;
}
// paramDataOutput.write(arrayOfString, 0, j + 2); int lengString = j+2; int lengthData=data.Length; byte[] temp=new byte[lengthData+lengString]; for(int i=0;i<lengthData;i++) temp[i]=data[i]; for(int i=0;i<lengString;i++) temp[lengthData+i]=arrayOfString[i]; data=temp; return j + 2; }
public byte[] getBytesArray() {return data;}
}