Проблема с селектором Java / SocketChannel - PullRequest
Новая
       17

Проблема с селектором Java / SocketChannel

0 голосов
/ 31 января 2010

У меня проблема с многопользовательской игрой. Сейчас я просто пытаюсь заставить сервер отправлять текущий уровень клиенту. Сервер определенно отправляет данные, но никогда не попадает в клиентское приложение.

Код клиента: 

    public void run() {
    while(true)
    {
        try {
            sel.select();
            Set readyKeys = sel.selectedKeys();
            Iterator itr = readyKeys.iterator();
            while(itr.hasNext())
            {
                SelectionKey key = (SelectionKey) itr.next();
                itr.remove();
                SocketChannel ch = (SocketChannel) key.channel();
                if(key.isReadable())
                {
                    inputbuf.clear();
                    long bytesRead = ch.read(inputbuf);
                    inputbuf.flip();
                    byte[] test = inputbuf.array();
                    {
                        for(int i=0; i < inputbuf.remaining(); i++)
                        {
                           System.out.print(test[i]+" ");
                        }
                    }
                    byte cmd = 0;
                    cmd = inputbuf.get();
                    switch(cmd)
                    {
                        case 1:
                           //do something
                        case 2:
                           //do something else
                        break;
                    }
                }
                else if(key.isConnectable())
                {
                    sc.finishConnect();
                    sc.register(sel, SelectionKey.OP_READ);
                }
            }
        } catch (IOException ex) {
            Buildsim.error("Error handling input from server", ex);
        }
    }
}

Код сервера: 

public RemotePlayer(SocketChannel s)
{
    sc = s;
    try {
        sel = Selector.open();
        sc.configureBlocking(false);
        sc.register(sel, SelectionKey.OP_WRITE);
        socket = sc.socket();
        ip = socket.getInetAddress().toString();
        System.out.println("New connection from "+ip);
        inputbuf = ByteBuffer.allocate(1048576);
        outputbuf = ByteBuffer.allocate(1048576);
        inputbuf.clear();
        outputbuf.clear();
    }
    catch(Exception e)
    {
        Buildsim.error("Connection error: ", e);
    }
    sendLevel();
}
public void sendObject(GameObject obj)
{
     //Sends a packet of the object, then does the same for the object's children
}
public void sendLevel()
{
    try {
        outputbuf.put((byte) 0x01);
        outputbuf.flip();
        sc.write(outputbuf);
        sendObject(Buildsim.w.parts.get(0)); //root object
    }
    catch(IOException e)
    {
        Buildsim.error("Error sending level to "+ip, e);
    }
}

Единственное, что попадает к клиенту, это байт 0x01 (сигнализирует об изменении уровня).

Заранее спасибо.

1 Ответ

0 голосов
/ 01 февраля 2010

Из-за объема информации, которую вы нам предоставили, мы можем давать только глобальные подсказки, такие как: вы убедились, что ваш поток сокетов не буферизован и что вы flush() после записи информации?

Возможно, данные ожидают в буфере, ожидая отправки для отправки.

Edit:

Вы установили SocketChannel в неблокирующий режим, так что вы правы, предполагая, что позаботится о сбросе на отправляющей стороне, я предполагаю, что клиент не буферизует свой ввод?

Возможно, проблема в том, что SocketChannel.write () не гарантируется для записи всего буфера, но может вернуться рано. Вам нужно заключить записи в цикл while, чтобы отслеживать записанные байты, чтобы убедиться, что ваши данные действительно записаны в канал. Процитирую Javadoc:

Если не указано иное, запись операция вернется только после запись всех r запрошенных байтов. Некоторые типы каналов, в зависимости от их состояние, может написать только некоторые из байты или, возможно, ни одного вообще. A канальный сокет в неблокирующем режиме , например, больше не могу писать байтов, чем свободно в сокете выходной буфер.

...