Всем привет. Я пишу простой TCP сервер, основанный на технологии NIO.
О возможных советах по использованию готовых решений, моя цитата из другой темы, там я о UDP спрашивал и вопрос был вообще о другом - "Почитал о MINA, Netty, но это показалось мне overkill-ом, так как мой сервак ничего не пишет/не отправляет, работает только как приемник. Ну и самое главное, захотелось для опыта пощупать технологию руками."
Наверное, многие сталкивались с таким примером в сети:
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.
while (true) {
try
{
selector.select();
// System.out.println("selected = "+x);
Set keys = selector.selectedKeys();
Iterator it = keys.iterator();
while(it.hasNext())
{
SelectionKey key = (SelectionKey)it.next();
if (key.isConnectable())
{
((SocketChannel)key.channel()).finishConnect();
}
if (key.isAcceptable())
{
SocketChannel client = server.accept();
client.configureBlocking(false);
client.socket().setTcpNoDelay(true);
client.register(selector, SelectionKey.OP_READ);
}
if (key.isReadable())
{
readMessage(key);
}
}
keys.clear();
}
этот пример работает. есть несколько вопросов:
1) во многих примерах проверка key.isConnectable() отсутствует, а где-то пишут, что это необходимо. Почитал об этом, говорят, что это нужно для правильного закрытия пришедшего соединения - не понял, надо ли это или нет?
2) вышеприведенный код в принципе работает. Но при больших нагрузках
рекомендуют прикрутить многопоточность. Я правильно понимаю, что надо создать ThreadPool и вместо текущего readMessage(key) делать что-то вроде
1.
Thread t = getThreadFromPool(); t.start(new MsgHandler(key))
, то есть осуществлять считывание инфы и ее обработку в отдельном потоке? Какие есть рекомендации, каие возможны подводные камни, какие объекты скорее всего придется синхронизировать? Можно ли сюда маленький, лаконичный псевдокод, дополняющий вышеприведенный псевдокод многопоточностью?
3) как логически корректно закрывать сокет? другими словами, когда делать key.channel.close()? ведь TCP соединение это как сессия, можно даже не разрывать его и пользоваться им, если сообщения от клиента поступают постоянно. Или лучше даже при постоянном приеме сообщений каждый раз разрывать соединение после считки сообщения? а если я не хочу разрывать соединение, значит обрыв соединения производим только при Exception-ах, правильно?
И еще, дополнение ко второму пункту о синхронизации - если я не разрываю соединения, значит при приеме сообщений от одних и тех же клиентов возможна ситуация, когда в одном потоке обрабатываю selectionKey и пока его обрабатываю, от этого же клиента приходит сообщение - а ведь selectionKey.channel будет тем же, мы же не разрываем соединения, помните? А это значит, я в двух разных потоках обрабатываю одновременно один и тот же объект, я прав?
4) еще очень часто в инете видел рекомендации по поводу реализации считки сообщений - говорят, что сообщения могут приходит хаотично, например начало сообщения, потом только его конец и я должен уметь распознавать цельные сообщения либо по наличию символа окончания строки, либо дополнять сообщение префиксом - количеством байт в сообщении и ждать именно столько байтов. А если я выделяю достаточно большой ByteBuffer могу ли я забить на такую хитрую обработку и считать то, что я считал из канала методом selectedChannel.read(someByteBuffer) цельным сообщением? Возможны ли ситуации, когда по каким-то причинам одно цельное сообщение теоретически помещающееся в буфер дробится на несколько мелких сообщений?
