소켓채널 등을 이용한 채팅프로그램

[앞 포스트를 이용한, 채팅프로그램]

[MessageHandler]

package basic;

import java.io.IOException;

import java.nio.ByteBuffer;

import java.nio.channels.SocketChannel;

public class MessageHandler {

public static void sendFixedMessage(SocketChannel socketChannel, String message) {

try {

ByteBuffer buffer = ByteBuffer.allocate(64);

buffer.put(message.getBytes());

buffer.flip();

while (buffer.hasRemaining()) {

socketChannel.write(buffer);

}

System.out.println("[Send Message] : " + message);

} catch (IOException e) {

e.printStackTrace();

}

}

public static String receiveFixedMessage(SocketChannel socketChannel) {

String message ="";

try {

ByteBuffer buffer = ByteBuffer.allocate(64);

socketChannel.read(buffer);

buffer.flip();

while(buffer.hasRemaining()) {

message += (char)buffer.get();

}

} catch (IOException e) {

e.printStackTrace();

}

return message;

}

}