UDP 3 Event

[Boris2105]

Нужна помощь с реализацией событий , поймать пакеты и разобрать смог.
Но вот реализовать не особо, может кто нибудь скинуть пример реализации например с хп.
Просто пример

BattleClientConnection

[SRC="java"]public class BattleClientConnection extends SimpleChannelInboundHandler<DatagramPacket>
{

private static final Logger log = ServiceManager.getLogger();
static byte[] data;
byte opcode;
byte slotID;
float time;
byte session;
short length;
short event1;
short event2;
ByteBuf InternalPacket;
int sub_opcode, slot, sub_length, EventType;
Room room;

@Override
protected void channelRead0(ChannelHandlerContext ctx, DatagramPacket msg) throws Exception
{
InetSocketAddress sender = msg.sender();
ByteBuf buf = msg.content().order(ByteOrder.LITTLE_ENDIAN);
opcode = buf.readByte();
slotID = buf.readByte();
time = buf.readFloat();
session = buf.readByte();
length = buf.readShort();
event1 = buf.readShort();
event2 = buf.readShort();
log.success("Opcode: " + opcode + " | slot: " + slotID + " | Time: " + time + " | Session: " + session + " | length: " + length + " | event 1,2: " + event1 + "|" + event2);
byte[] array = new byte[length - 13];
buf.readBytes(array);
InternalPacket = Unpooled.copiedBuffer(array).order(ByteOrder.LITTLE_ENDIAN);
ByteBuf originalbuffer = Unpooled.copiedBuffer(array).order(ByteOrder.LITTLE_ENDIAN);
switch (opcode)
{
case 3:
log.debug("Packet Replication Opcode 3 Slot :" + slotID);
if (this.room != null)
{
onlyDecrypt(originalbuffer, length);
sub_opcode = originalbuffer.readByte();
slot = originalbuffer.readShort();
sub_length = originalbuffer.readShort();
EventType = 0;
if (sub_opcode != 2)
{
EventType = originalbuffer.readInt();
}
System.out.println("| Sub-Opcode: " + sub_opcode + " | Slot: " + slot + "| length: " + sub_length + " | EventType: " + EventType + " |");
ByteBuf _buf = Unpooled.buffer(0, this.length).order(ByteOrder.LITTLE_ENDIAN);
_buf.writeByte(4); // OPCODE
_buf.writeByte(-1); // SLOT
_buf.writeFloat(time); // TIME
_buf.writeByte(1); // SESSION
_buf.writeShort(this.length); // LENGTH
_buf.writeShort(0); // EVENT 1
_buf.writeShort(0); // EVENT 2
_buf.writeBytes(InternalPacket.copy());
for (Player p : this.room.getPlayers().values())
{
// System.out.println(NetworkUtil.printData("Buffer OutPut 3", _buf));
ctx.writeAndFlush(new DatagramPacket(_buf.copy(), p.net));
log.warn("Relay Packet send to > " + p.slotID);
}
}
break;
case 4:
log.debug("Packet Replication Opcode 4 Slot :" + slotID);
if (this.room != null)
{
for (Player p : this.room.getPlayers().values())
{

ByteBuf _buf = Unpooled.buffer(0, this.length).order(ByteOrder.LITTLE_ENDIAN);
_buf.writeByte(4); // OPCODE
_buf.writeByte(-1); // SLOT
_buf.writeFloat(time); // TIME
_buf.writeByte(1); // SESSION
_buf.writeShort(this.length); // LENGTH
_buf.writeShort(0); // EVENT 1
_buf.writeShort(0); // EVENT 2
_buf.writeBytes(InternalPacket.copy());
ctx.writeAndFlush(new DatagramPacket(_buf, p.net));
log.warn("Relay Packet send to > " + p.slotID);
}
}
break;
case 65:
log.debug("Player Trying to connect to Server IP: " + msg.sender().getHostString() + " | Port: " + msg.sender().getPort());
onlyDecrypt(InternalPacket, length);
int unknown = InternalPacket.readInt();
int roomID = InternalPacket.readInt();
int roomSeed = InternalPacket.readInt();
log.debug("Room ID: " + roomID + " | Room SEED: " + roomSeed);

Room room = RoomController.getInstance().getRoom(roomID);
if (room != null)
{
log.debug("Room " + roomID + " is registered, Searching for Slot: " + slotID);
Player p = room.getPlayerBySlot(slotID);
if (p != null)
{
log.debug("Slot Founded !!!");
p.net = new InetSocketAddress(sender.getHostName(), sender.getPort());
//p.room = room; --временно
p.ctx = ctx;
this.room = room;
// Packet 66
ByteBuf _buf = Unpooled.buffer(0, 14).order(ByteOrder.LITTLE_ENDIAN);
_buf.writeByte(66); // OPCODE
_buf.writeByte(0); // SLOT
_buf.writeFloat(time); // TIME
_buf.writeByte(1); // SESSION
_buf.writeShort(14); // LENGTH
_buf.writeShort(0); // EVENT 1
_buf.writeShort(0); // EVENT 2
_buf.writeByte(8);
ctx.writeAndFlush(new DatagramPacket(_buf, p.net));
log.debug("Packet 66 Send");

Thread t = new Thread(new Runnable()
{

@Override
public void run()
{

}
});
t.start();
}
}
PrintInfo.getInstance().printSection("End Packet 65");
break;
default:
//log.warn("UNHANDLED PACKET");
break;
}

}

@Override
public void exceptionCaught(
ChannelHandlerContext ctx, Throwable cause)
throws Exception
{
cause.printStackTrace();
}

public static void onlyDecrypt(ByteBuf buf, int length)
{
data = buf.array();
byte lastElement = data[data.length - 1];
for (int i = data.length - 1; i > 0; i--)
{
data[i] = (byte) (((data[i - 1] & 0xFF) << (8 - getShift(length))) | ((data[i] & 0xFF) >> getShift(length)));
}
data[0] = (byte) ((lastElement << (8 - getShift(length))) | ((data[0] & 0xFF) >> getShift(length)));
// System.out.println(NetworkUtil.printData("Decoded [shift: " + getShift(length) + "]", buf));
}

public static void Shift(ByteBuf buffer, int bits)
{
data = buffer.array();
int length = data.length;
byte first = data[0];
byte current;

for (int i = 0; i < length; i++)
{
if (i >= (length - 1))
{
current = first;
} else
{
current = data[i + 1];
}

data[i] = (byte) (current >> (8 - bits) | (data[i] << bits));
}
}

public static int getShift(int length)
{
return length % 6 + 1;
}

public static void Shift(byte[] buffer, int bits)
{
int length = buffer.length;
byte first = buffer[0];
byte current;

for (int i = 0; i < length; i++)
{
if (i >= (length - 1))
{
current = first;
} else
{
current = buffer[i + 1];
}

buffer[i] = (byte) (current >> (8 - bits) | (buffer[i] << bits));
}
}
}
[/SRC]

[PROGRAMMATOR]

EventType = originalbuffer.readInt();

Вот здесь ты считываешь события (маску). Проверяй, есть ли определённый флаг в events и делай, что нужно.

К примеру в клиенте просто последовательно:

[SRC="csharp"]if (events.HasFlag(GameEventType.RadioChat))
{
// ...
}

if (events.HasFlag(GameEventType.WeaponSync))
{
// ...
}

if (events.HasFlag(GameEventType.HpSync))
{
var hp = reader.ReadInt16();

// ...

events ^= GameEventType.HpSync;
}

// ...
[/SRC]


Только синхронизировать вот так вот ХП не имеет смысла, нужно самому отправлять HpSync после получения урона игроком, а иначе это "дыра" для читеров. Пример его отправки я описывал в теме https://forum.zone-game.info/showthread.php?t=41671

Пока займись разбором всех событий.

[Boris2105]

Вот здесь ты считываешь события (маску). Проверяй, есть ли определённый флаг в events и делай, что нужно.

К примеру в клиенте просто последовательно:

[SRC="csharp"]if (events.HasFlag(GameEventType.RadioChat))
{
// ...
}

if (events.HasFlag(GameEventType.WeaponSync))
{
// ...
}

if (events.HasFlag(GameEventType.HpSync))
{
var hp = reader.ReadInt16();

// ...

events ^= GameEventType.HpSync;
}

// ...
[/SRC]


Только синхронизировать вот так вот ХП не имеет смысла, нужно самому отправлять HpSync после получения урона игроком, а иначе это "дыра" для читеров. Пример его отправки я описывал в теме https://forum.zone-game.info/showthread.php?t=41671

Пока займись разбором всех событий.

хорошо , это я понял. Но вот маску событий сделать тут
[SRC=csharp]
EventType = originalbuffer.readInt();
[/SRC]
но вот эти события записать в 4 опкод или как их вызывать?
и как будет меняться информация из 3 пакета

[PROGRAMMATOR]

3 и 4 - это один и тот же пакет.
По вопросу "как их вызывать" ничего не понял.

[Boris2105]

3 и 4 - это один и тот же пакет.
По вопросу "как их вызывать" ничего не понял.

это я знаю , я про события

Код:

00 // SubHead.User
00 00 // Slot 0
15 00 // Size
04 00 00 00 // Events.PosRotation
CA 47 // X
B6 00 // Y
FE 48 // Z
BA 4D // CamX
FB D4 // CamY
03 00 // Area

вот например пакет о позиции игрока

Код:

08 // SubHead.StageInfoChara
00 00 // Slot 0
0b 00 // Size
00 10 00 00 // Events.HpSync
00 1c // HP

а это уже пакет о хп
то есть как менять пакеты в 3 и 4 опкоде, мб так понятнее

[PROGRAMMATOR]

[SRC="csharp"]case 3:
case 4:
// GameEventType.PosRotation | GameEventType.HpSync (260)
var events = (GameEventType)reader.ReadInt32();

// Читаем 0x04
if (events.HasFlag(GameEventType.PosRotation))
{
var posX = reader.ReadUInt16();
var posY = reader.ReadUInt16();
var posZ = reader.ReadUInt16();

var camX = reader.ReadUInt16();
var camY = reader.ReadUInt16();
var area = reader.ReadUInt16();

var position = new Half3(posX, posY, posZ);
var camera = new Half2(camX, camY);

// room.ValidatePosition(position);

events ^= GameEventType.PosRotation;
}

// Читаем 0x100
if (events.HasFlag(GameEventType.HpSync))
{
var hp = reader.ReadInt16();

// ...

events ^= GameEventType.HpSync;
}

log.Debug($"Необработанные события: {events}");
break;
[/SRC]


Ну и собирай из полученных данных новый пакет со своими событиями, грубо говоря в обратном порядке.