FilesExpand file tree

master

/

DataPack.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

47 lines (39 loc) · 1.46 KB

master

/

DataPack.java

Copy path

Top

File metadata and controls

• Code
• Blame

47 lines (39 loc) · 1.46 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

package com.modulecode.net.impl;

import com.modulecode.exception.PackageMaxException;

import com.modulecode.net.IDataPack;

import com.modulecode.net.IMessage;

import com.modulecode.utils.Global;

import java.io.*;

public class DataPack implements IDataPack {

@Override

public int getHeadLen() {

return 8;

}

@Override

public byte[] pack(IMessage msg) throws IOException {

//创建一个输出缓冲区并写入

ByteArrayOutputStream dataBuff = new ByteArrayOutputStream();

DataOutputStream dataOutputStream = new DataOutputStream(dataBuff);

dataOutputStream.writeInt(msg.getDataLen());

dataOutputStream.writeInt(msg.getMsgID());

dataOutputStream.write(msg.getData());

return dataBuff.toByteArray();

}

@Override

public IMessage unPack(InputStream inputStream) throws IOException {

//创建一个输入缓冲区并读取

DataInputStream dataInputStream = new DataInputStream(inputStream);

int len = dataInputStream.readInt();

//读取的id

int id = dataInputStream.readInt();

//每次一次性读取多少字节

byte[] bytesData = new byte[len];

dataInputStream.read(bytesData);

int maxPackageSize = Global.global.reloadGinxConfig().getMaxPackageSize();

//判断长度

if (len > maxPackageSize) {

throw new PackageMaxException();

}

return new Message(id, len, bytesData);

}

}