Параллельное чтение / запись именованного канала в Java (в Windows)

Question

Я пытаюсь обеспечить связь между приложением C # и приложением Java в Windows, используя именованные каналы с помощью метода, описанного v01ver в этом вопросе: Как открыть именованный канал Windows из Java?

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

final RandomAccessFile pipe;
try {
   pipe = new RandomAccessFile("\\\\.\\pipe\\mypipe", "rw");
}
catch (FileNotFoundException ex) {
   ex.printStackTrace();
   return;
}

Thread readerThread = new Thread(new Runnable() {
   @Override
   public void run() {
      String line = null;
      try {
         while (null != (line = pipe.readLine())) {
            System.out.println(line);
         }
      }
      catch (IOException ex) {
         ex.printStackTrace();
      }
   }
});
readerThread.start();

try { Thread.sleep(500); } catch (InterruptedException e) {}

try {
   System.out.println("Writing a message...");
   pipe.write("Hello there.\n".getBytes());
   System.out.println("Finished.");
}
catch (IOException ex) {
   ex.printStackTrace();
}

Вывод:

Writing a message...

и затем он ждет вечно.

Как я могу записать в именованный канал, ожидая ввода в другом потоке?

Answer 1

Это ожидаемое поведение труб.Он должен зависать, пока другой процесс не подключится к каналу и не прочитает его.

Answer 2

У меня та же проблема - связь между приложением C # / Python и приложением Java в окнах с использованием именованных каналов:

У нас есть пример клиентского кода, написанного на Java, но в строке String echoResponse = pipe.readLine(); treadждет вечно.

try {
    // Connect to the pipe
    RandomAccessFile pipe = new RandomAccessFile("\\\\.\\pipe\\testpipe", "rw");
    String echoText = "Hello word\n";
    // write to pipe
    pipe.write ( echoText.getBytes() );
    // read response
    String echoResponse = pipe.readLine();
    System.out.println("Response: " + echoResponse );
    pipe.close();

    } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
    }

Решение проблемы: у меня есть код ServerPipe, написанный на Python отсюда Пример кода - Named Pipes : и запустить его на Python 2.6.6

from ctypes import *

PIPE_ACCESS_DUPLEX = 0x3
PIPE_TYPE_MESSAGE = 0x4
PIPE_READMODE_MESSAGE = 0x2
PIPE_WAIT = 0
PIPE_UNLIMITED_INSTANCES = 255
BUFSIZE = 4096
NMPWAIT_USE_DEFAULT_WAIT = 0
INVALID_HANDLE_VALUE = -1
ERROR_PIPE_CONNECTED = 535

MESSAGE = "Default answer from server\0"
szPipename = "\\\\.\\pipe\\mynamedpipe"


def ReadWrite_ClientPipe_Thread(hPipe):
    chBuf = create_string_buffer(BUFSIZE)
    cbRead = c_ulong(0)
    while 1:
        fSuccess = windll.kernel32.ReadFile(hPipe, chBuf, BUFSIZE,
byref(cbRead), None)
        if ((fSuccess ==1) or (cbRead.value != 0)):
            print chBuf.value
            cbWritten = c_ulong(0)
            fSuccess = windll.kernel32.WriteFile(hPipe,
                                                 c_char_p(MESSAGE),
                                                 len(MESSAGE),
                                                 byref(cbWritten),
                                                 None
                                                )
        else:
            break
        if ( (not fSuccess) or (len(MESSAGE) != cbWritten.value)):
            print "Could not reply to the client's request from the
pipe"
            break
        else:
            print "Number of bytes written:", cbWritten.value

    windll.kernel32.FlushFileBuffers(hPipe)
    windll.kernel32.DisconnectNamedPipe(hPipe)
    windll.kernel32.CloseHandle(hPipe)
    return 0

def main():
    THREADFUNC = CFUNCTYPE(c_int, c_int)
    thread_func = THREADFUNC(ReadWrite_ClientPipe_Thread)
    while 1:
        hPipe = windll.kernel32.CreateNamedPipeA(szPipename,
                                                 PIPE_ACCESS_DUPLEX,
                                                 PIPE_TYPE_MESSAGE |
                                                 PIPE_READMODE_MESSAGE
|
                                                 PIPE_WAIT,

PIPE_UNLIMITED_INSTANCES,
                                                 BUFSIZE, BUFSIZE,

NMPWAIT_USE_DEFAULT_WAIT,
                                                 None
                                                )
        if (hPipe == INVALID_HANDLE_VALUE):
            print "Error in creating Named Pipe"
            return 0

        fConnected = windll.kernel32.ConnectNamedPipe(hPipe, None)
        if ((fConnected == 0) and (windll.kernel32.GetLastError() ==
ERROR_PIPE_CONNECTED)):
            fConnected = 1
        if (fConnected == 1):
            dwThreadId = c_ulong(0)
            hThread = windll.kernel32.CreateThread(None, 0,
thread_func, hPipe, 0, byref(dwThreadId))
            if (hThread == -1):
                print "Create Thread failed"
                return 0
            else:
                windll.kernel32.CloseHandle(hThread)
        else:
            print "Could not connect to the Named Pipe"
            windll.kernel32.CloseHandle(hPipe)
    return 0


if __name__ == "__main__":
    main()

После запуска сервера вы можете использовать слегка измененную версию кода клиента Java:

try {
    // Connect to the pipe
    RandomAccessFile pipe = new RandomAccessFile("\\\\.\\pipe\\mynamedpipe", "rw");
    String echoText = "Hello world\n";
    // write to pipe
    pipe.write(echoText.getBytes());

    //String aChar;
    StringBuffer fullString = new StringBuffer();

    while(true){
        int charCode = pipe.read();
        if(charCode == 0) break;
        //aChar = new Character((char)charCode).toString();
        fullString.append((char)charCode);
    }

    System.out.println("Response: " + fullString);
    pipe.close();
}
catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}

Хорошо работает в NetBeans 6.9.1.

Answer 3

Полагаю, что RandomAccessFile здесь не тот API.Попробуйте FileInputStream + FileOutputStream на стороне Java.Но это только предположение, поскольку я последний раз использовал Windows API во времена, когда именованные каналы еще не существовали.

Answer 4

Я не знаком с JAVA, и мой C # тоже довольно элементарный.Однако у меня была похожая проблема с многопоточным клиентом C ++, которую я исправил, открыв канал для перекрывающегося ввода-вывода.Пока я не сделал этого, Windows сериализовала операции чтения и записи, фактически приводя к тому, что неудовлетворенный (блокирующий) файл ReadFile предотвращал завершение последующего файла WriteFile до тех пор, пока чтение не было завершено.FILE_FLAG_OVERLAPPED

Answer 5

Не волнуйтесь, использование RandomAccessFile для доступа к именованному каналу является правильным. Именованный канал - это объект файловой системы. Под Linux / Unix это также называется "fifo". Эти объекты читаются как файл. (и не то же самое, что каналы, используемые между процессами, которые абстрагированы классом Java Pipe).

Однако я вижу две проблемы с вашей программой. Я не могу проверить это в настоящее время, поскольку мне нужен ваш тестовый сервер (не стесняйтесь публиковать). Ваш читательский поток ждет ответов с другой стороны (т.е. с сервера). Он использует readLine (), я бы использовал другой метод (для отладки чтение char по char может быть лучшим).

С Java (без JNI) вы не можете создать именованный канал (на стороне сервера). Открыв именованный канал с помощью универсального метода, используемого RandomAccessFile, вы получите поток байтового типа, который может быть односторонним или дуплексным.

Кстати: JTDS (бесплатный драйвер JDBC для SQL Server) может дополнительно использовать именованный канал для доступа к серверу SQL, даже по сети. И он использует именно метод RandomAccessFile.

Кстати: на старых установочных носителях MS SQL Server есть тестовый сервер makepipe.exe, однако я не нашел надежного источника для получения этого файла.