Fortran 和 C# 之间的管道

如何解决Fortran 和 C# 之间的管道

我想在 Fortran 程序和 C# 程序之间建立一个管道。 Fortran 程序将完成繁重的工作，C# 程序将提供正在执行的操作的“视图”（使用从 Fortran 程序发送给它的数据）。为了检查这是否有效，我编写了两个小程序。 （Fortran 代码是从 C++ 和 C# 之间的管道数据示例中挖出来的。）

Fortran 代码：

  PROGRAM Test

  USE kernel32
  IMPLICIT NONE

  ! Data pipe
  INTEGER*4 EqnData /100/
  ! Paths for pipes
  CHaraCTER*128 dataname /'\\.\pipe\EqnData'/

  INTEGER(HANDLE) :: pipe1

  pipe1 = CreateNamedPipe('\\\\.\\pipe\\EqnData'C,PIPE_ACCESS_DUPLEX,&
    PIPE_WAIT,PIPE_UNLIMITED_INSTANCES,&
    1024,1024,120 * 1000,NULL)

  PRINT*,pipe1

  ! Open data pipe
  OPEN(UNIT=EqnData,FILE=dataname,ACCESS='STREAM',STATUS='OLD')

  READ* 

  ! Close pipe
  CLOSE(EqnData)

  WRITE (*,*) 'end'

  END

C# 代码：

using System;
using System.IO;
using System.IO.Pipes;

class PipeClient
{
  static void Main(string[] args)
  {

    using (NamedPipeClientStream pipeClient
      = new NamedPipeClientStream(".","EqnData",PipeDirection.InOut))
    {
      // Connect to the pipe or wait until the pipe is available.
      Console.Write("Attempting to connect to pipe...");
      pipeClient.Connect();

      Console.WriteLine("Connected to pipe.");
      Console.WriteLine("There are currently {0} pipe server instances open.",pipeClient.NumberOfServerInstances);
      using (StreamReader sr = new StreamReader(pipeClient))
      {
        // display the read text to the console
        string temp;
        while ((temp = sr.ReadLine()) != null)
        {
          Console.WriteLine("Received from server: {0}",temp);
        }
      }
    }
    Console.Write("Press Enter to continue...");
    Console.ReadLine();
  }
}

如果我启动这两个程序，我会看到 Fortran 代码创建了一个管道，它深入到 READ 语句，但 C# 代码只到达 pipeClient.Connect() 然后就在那里.

我是否正确设置了 C# 方面的内容？或者也许我在 Fortran 方面没有完全正确的东西，以便 C# 客户端“看到”管道？

解决方法

@Cup 是对的。添加到管道的连接并切换到 WriteFile 工作。 Fortran 代码：

  program Test

  use kernel32
  implicit none

  ! Pipes
  integer(HANDLE) :: pipe
  character*128 dataname /'\\.\pipe\EqnData'/
  ! Flags
  integer :: connectNamedPipeErrFlag,errorCode,writeFileErrFlag
  ! Data to send
  character*128 :: message

  pipe = CreateNamedPipe( &                       ! CreateNamesPipe: Creates an instance of a named pipe and returns a handle for subsequent pipe operations
    !                                               https://docs.microsoft.com/en-us/windows/win32/api/winbase/nf-winbase-createnamedpipea
    '\\.\pipe\EqnData',&                         ! lpName: Unique pipe nam in th following form: \\.\pipe\pipename
    PIPE_ACCESS_DUPLEX,&                         ! dwOpenMode: Open mode (eg. PIPE_ACCESS_DUPLEX,PIPE_ACCESS_INBOUND,PIPE_ACCESS_OUTBOUND,etc.)
    PIPE_WAIT,&                                  ! dwPipeMode: Pipe mode (eg. PIPE_WAIT,etc.)
    PIPE_UNLIMITED_INSTANCES,&                   ! nMaxInstances: Maximum number of instances that can be created for this pipe
    1024,&                                       ! nOutBufferSize: Number of bytes to reserve for the output buffer
    1024,&                                       ! nInBufferSize: Number of bytes to reserve for the input buffer
    120 * 1000,&                                 ! nDefaultTimeOut: Default time-out value,in milliseconds
    NULL)                                         ! lpSecurityAttributes: A pointer to a SECURITY_ATTRIBUTES structure
  if(pipe .NE. INVALID_HANDLE_VALUE) then
    write (*,*) 'Pipe created'
  else
    ! TODO:
  endif

  connectNamedPipeErrFlag = ConnectNamedPipe( &   ! ConnectNamedPipe: Returned nonzero value if the connection is successful
    !                                               https://docs.microsoft.com/en-us/windows/win32/api/namedpipeapi/nf-namedpipeapi-connectnamedpipe
    pipe,&                                       ! hNamedPipe: Handle to the server end of a named pipe instance (returned by the CreateNamedPipe function)
    NULL)                                         ! lpOverlapped: A pointer to an OVERLAPPED structure
  if(connectNamedPipeErrFlag .NE. 0) then
    write(*,*) 'Pipe connected'
  else
    ! TODO:
  endif

  message = 'Some data'

  writeFileErrFlag = WriteFile( &                 ! Writes data to the specified file or IO device
    !                                               https://docs.microsoft.com/en-us/windows/win32/api/fileapi/nf-fileapi-writefile
    pipe,&                                       ! hfile: A handle to the file or IO device
    loc(message),&                               ! lpBuffer: A pointer to the buffer containing the data to be written to the file or device.
    len(trim(message)),&                         ! nNumberOfBytesToWrite: Number of bytes to write
    0,&                                          ! lpNumberOfBytesWritten: number of bytes that were written
    NULL)                                         ! lpOverlapped:
  if (writeFileErrFlag .NE. 0) then
    write (*,*) 'Write successful'
  else
    errorCode = GetLastError()
    if(errorCode .EQ. ERROR_IO_PENDING) then
      ! TODO:
    elseif (errorCode .EQ. ERROR_INVALID_USER_BUFFER ) then
      ! TODO:
    elseif(errorCode .EQ. ERROR_NOT_ENOUGH_MEMORY ) then
      ! TODO:
    elseif(errorCode .EQ. ERROR_OPERATION_ABORTED) then
      ! TODO:
    elseif(errorCode .EQ. ERROR_NOT_ENOUGH_QUOTA) then
      ! TODO:
    else
      ! TODO:
    endif
  endif

  close(pipe)

  write(*,*) 'Pipe closed'

  end program