Привет всем, мне нужна помощь с передачей данных через SocketChannel всё вроде работает, но вот данные при получении сдвигаются если ByteBuffer имеет больший размер чем сам массив , как этого избежать при этом не уменьшая буферы.
//Server
new Thread() {
public void run() {
try {
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.socket().bind(new InetSocketAddress(1337));
SocketChannel socketChannel = serverSocketChannel.accept();
ByteBuffer buf = ByteBuffer.allocate(10);
byte[] data = { 1, 2, 3 };
while (!socketChannel.finishConnect()) {
Thread.sleep(100);
}
while (true) {
buf.put(data);
buf.flip();
socketChannel.write(buf);
buf.clear();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}.start();
//Client
new Thread() {
public void run() {
try {
SocketChannel socketChannel = SocketChannel.open();
socketChannel.connect(new InetSocketAddress("localhost", 1337));
ByteBuffer buf = ByteBuffer.allocate(4);
while (!socketChannel.finishConnect()) {
Thread.sleep(100);
}
while (true) {
Thread.sleep(100);
socketChannel.read(buf);
System.out.println(buf.array()[0] + " " + buf.array()[1] + " " + buf.array()[2]);
buf.clear();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}.start();
}
Вывод программы:
1 2 3
2 3 1
3 1 2