using cn.org.hentai.tentacle.util;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace cn.org.hentai.tentacle.protocol
{
public class Packet
{
// 实际数据长度(头部 数据体)
int size = 0;
// 当前读写指针索引位置
int offset = 0;
// 包数据体最大大小
int maxSize = 0;
// 头部 数据体 可能冗余的空间
public byte[] data;
private Packet()
{
// do nothing here..
}
public static Packet from(byte[] data)
{
Packet packet = new Packet();
packet.data = data;
packet.size = data.Length;
return packet;
}
public static Packet read(Stream stream, int bytesInBuffer)
{
if (bytesInBuffer < 11) return null;
byte[] head = new byte[11];
int len = stream.Read(head, 0, 11);
int dataLength = ByteUtil.getInt(head, 7, 4) & 0x7fffff;
using (MemoryStream ms = new MemoryStream(dataLength 10))
{
byte[] buff = new byte[512];
for (int i = 0; i < dataLength; i = len)
{
len = stream.Read(buff, 0, Math.Min(512, dataLength - i));
if (len == -1) break;
ms.Write(buff, 0, len);
}
Packet p = new Packet();
p.data = new byte[dataLength 6 1 4];
p.size = 0;
p.maxSize = p.size;
p.addBytes(head);
p.addBytes(ms.ToArray());
buff = null;
head = null;
return p;
}
}
/**
* 创建协议数据包
* @param command 指令,参见cn.org.hentai.tentacle.protocol.Command类
* @param length 数据包的长度
* @return
*/
public static Packet create(byte command, int length)
{
Packet p = new Packet();
p.data = new byte[length 6 1 4];
p.data[0] = (byte)'H';
p.data[1] = (byte)'E';
p.data[2] = (byte)'N';
p.data[3] = (byte)'T';
p.data[4] = (byte)'A';
p.data[5] = (byte)'I';
p.data[6] = command;
Array.Copy(ByteUtil.toBytes(length), 0, p.data, 7, 4);
p.size = 11;
p.maxSize = length;
return p;
}
public int getSize()
{
return this.size;
}
public Packet addByte(byte b)
{
this.data[size ] = b;
return this;
}
public Packet addShort(short s)
{
this.data[size ] = (byte)((s >> 8) & 0xff);
this.data[size ] = (byte)(s & 0xff);
return this;
}
public Packet addInt(int i)
{
this.data[size ] = (byte)((i >> 24) & 0xff);
this.data[size ] = (byte)((i >> 16) & 0xff);
this.data[size ] = (byte)((i >> 8) & 0xff);
this.data[size ] = (byte)(i & 0xff);
return this;
}
public Packet addLong(long l)
{
this.data[size ] = (byte)((l >> 56) & 0xff);
this.data[size ] = (byte)((l >> 48) & 0xff);
this.data[size ] = (byte)((l >> 40) & 0xff);
this.data[size ] = (byte)((l >> 32) & 0xff);
this.data[size ] = (byte)((l >> 24) & 0xff);
this.data[size ] = (byte)((l >> 16) & 0xff);
this.data[size ] = (byte)((l >> 8) & 0xff);
this.data[size ] = (byte)(l & 0xff);
return this;
}
public Packet addBytes(byte[] b)
{
Array.Copy(b, 0, this.data, size, b.Length);
size = b.Length;
return this;
}
public Packet rewind()
{
this.offset = 0;
return this;
}
public byte nextByte()
{
return this.data[offset ];
}
public short nextShort()
{
return (short)(((this.data[offset ] & 0xff) << 8) | (this.data[offset ] & 0xff));
}
public int nextInt()
{
return (this.data[offset ] & 0xff) << 24 | (this.data[offset ] & 0xff) << 16 | (this.data[offset ] & 0xff) << 8 | (this.data[offset ] & 0xff);
}
public long nextLong()
{
return ((long)this.data[offset ] & 0xff) << 56
| ((long)this.data[offset ] & 0xff) << 48
| ((long)this.data[offset ] & 0xff) << 40
| ((long)this.data[offset ] & 0xff) << 32
| ((long)this.data[offset ] & 0xff) << 24
| ((long)this.data[offset ] & 0xff) << 16
| ((long)this.data[offset ] & 0xff) << 8
| ((long)this.data[offset ] & 0xff);
}
public byte[] nextBytes(int length)
{
byte[] buf = new byte[length];
Array.Copy(this.data, offset, buf, 0, length);
offset = length;
return buf;
}
public Packet skip(int offset)
{
this.offset = offset;
return this;
}
public Packet seek(int index)
{
this.offset = index;
return this;
}
public byte[] getBytes()
{
if (size == maxSize) return this.data;
else
{
byte[] buff = new byte[size];
Array.Copy(this.data, 0, buff, 0, size);
return buff;
}
}
}
}
资源文件列表
tentacle-client-win-master/.gitattributes , 2518
tentacle-client-win-master/.gitignore , 4305
tentacle-client-win-master/LICENSE , 551
tentacle-client-win-master/README.md , 394
tentacle-client-win-master/tentacle-client-win.sln , 5532
tentacle-client-win-master/tentacle-lib/Properties/AssemblyInfo.cs , 1286
tentacle-client-win-master/tentacle-lib/app.config , 158
tentacle-client-win-master/tentacle-lib/compress/BaseCompressProcessor.cs , 250
tentacle-client-win-master/tentacle-lib/compress/CompressUtil.cs , 803
tentacle-client-win-master/tentacle-lib/compress/RLEncoding.cs , 8229
tentacle-client-win-master/tentacle-lib/display/DesktopMirror.cs , 9375
tentacle-client-win-master/tentacle-lib/display/DisplayContext.cs , 5241
tentacle-client-win-master/tentacle-lib/display/Interop.cs , 4911
tentacle-client-win-master/tentacle-lib/graphic/Screenshot.cs , 1124
tentacle-client-win-master/tentacle-lib/hid/HIDCommand.cs , 484
tentacle-client-win-master/tentacle-lib/hid/KeyMapping.cs , 528
tentacle-client-win-master/tentacle-lib/hid/KeyboardCommand.cs , 569
tentacle-client-win-master/tentacle-lib/hid/MouseCommand.cs , 876
tentacle-client-win-master/tentacle-lib/protocol/Command.cs , 1965
tentacle-client-win-master/tentacle-lib/protocol/Packet.cs , 5861
tentacle-client-win-master/tentacle-lib/system/ClipboardAsync.cs , 1777
tentacle-client-win-master/tentacle-lib/system/File.cs , 930
tentacle-client-win-master/tentacle-lib/system/FileSystem.cs , 1702
tentacle-client-win-master/tentacle-lib/system/LocalComputer.cs , 200
tentacle-client-win-master/tentacle-lib/system/MouseCtrl.cs , 2950
tentacle-client-win-master/tentacle-lib/system/Robot.cs , 2401
tentacle-client-win-master/tentacle-lib/tentacle-lib.csproj , 3418
tentacle-client-win-master/tentacle-lib/util/BlockingQueue.cs , 2109
tentacle-client-win-master/tentacle-lib/util/ByteUtil.cs , 4798
tentacle-client-win-master/tentacle-lib/util/ByteWriter.cs , 3167
tentacle-client-win-master/tentacle-lib/util/Configs.cs , 2348
tentacle-client-win-master/tentacle-lib/util/SocketClient.cs , 3126
tentacle-client-win-master/tentacle-lib/util/TimeUtil.cs , 300
tentacle-client-win-master/tentacle-lib/util/Worker.cs , 1743
tentacle-client-win-master/tentacle-service/Program.cs , 515
tentacle-client-win-master/tentacle-service/Properties/AssemblyInfo.cs , 1292
tentacle-client-win-master/tentacle-service/TentacleService.Designer.cs , 1081
tentacle-client-win-master/tentacle-service/TentacleService.cs , 512
tentacle-client-win-master/tentacle-service/app.config , 158
tentacle-client-win-master/tentacle-service/tentacle-service.csproj , 2384
tentacle-client-win-master/tentacle-win/Program.cs , 470
tentacle-client-win-master/tentacle-win/Properties/AssemblyInfo.cs , 1286
tentacle-client-win-master/tentacle-win/Properties/Resources.Designer.cs , 2822
tentacle-client-win-master/tentacle-win/Properties/Resources.resx , 5496
tentacle-client-win-master/tentacle-win/Properties/Settings.Designer.cs , 1096
tentacle-client-win-master/tentacle-win/Properties/Settings.settings , 242
tentacle-client-win-master/tentacle-win/Tentacle.Designer.cs , 2399
tentacle-client-win-master/tentacle-win/Tentacle.cs , 1064
tentacle-client-win-master/tentacle-win/Tentacle.resx , 31148
tentacle-client-win-master/tentacle-win/app.config , 162
tentacle-client-win-master/tentacle-win/app/TentacleApp.cs , 10068
tentacle-client-win-master/tentacle-win/app/worker/CaptureWorker.cs , 847
tentacle-client-win-master/tentacle-win/app/worker/CompressWorker.cs , 3451
tentacle-client-win-master/tentacle-win/app/worker/FileTransferWorker.cs , 1494
tentacle-client-win-master/tentacle-win/app/worker/HIDCommandExecutor.cs , 1549
tentacle-client-win-master/tentacle-win/app/worker/HeartbeatSender.cs , 779
tentacle-client-win-master/tentacle-win/config.ini , 44
tentacle-client-win-master/tentacle-win/res/tentacle.ico , 16958
tentacle-client-win-master/tentacle-win/tentacle-win.csproj , 4160
