时间戳

首页 > 解决方案 > 使用命名管道将图像帧从 C++ 服务器发送到 C# 客户端

c# - 使用命名管道将图像帧从 C++ 服务器发送到 C# 客户端

问题描述

我是菜鸟IPC。我正在尝试将图像帧从我的发送C++ Server到C# Client. 我已经开始了解这一点，并制作了一个小的Client和Server我C++ Server发送的那个Hello。我看到了一个相关的问题，有人告诉我首先将其转换Image为Byte Array然后以相同的方式发送，Hello Message但我无法做到这一点。

我的基本客户端服务器代码

C++ 代码：

    Mat image = imread("IMG_0_10_34_45_2018_1.bmp");
uchar buffer[500][500];
for (int i = 0; i < image.rows; i++)
{
    for (int j = 0; j < image.cols; j++)
    {
        buffer[i][j] = image.at<unsigned char>(i, j);
    }
}
cout << "Server Creating Pipe\n";
HANDLE hPipe = ::CreateNamedPipe(_T("\\\\.\\pipe\\HyperPipe"),
    PIPE_ACCESS_DUPLEX,
    PIPE_TYPE_BYTE | PIPE_READMODE_BYTE,
    PIPE_UNLIMITED_INSTANCES,
    4096,
    4096,
    0,
    NULL);

cout << "Server Created Succesfully";
ConnectNamedPipe(hPipe, NULL);

cout << "Sending Message to Client";
DWORD bytesWritten = 0;
WriteFile(hPipe, buffer, sizeof(buffer) * sizeof(uchar), &bytesWritten, NULL);
CloseHandle(hPipe);
return 0;

和 C# 代码：

static void Main(string[] args)
{
    Console.WriteLine("Creating Client Pipe");
    NamedPipeClientStream pipe = new NamedPipeClientStream(".", "HyperPipe", PipeDirection.InOut);
    Console.WriteLine("Pipe Created Successfully, Connecting to Server");
    pipe.Connect();
    Console.WriteLine("Successfully, Connected to Server");
    using (StreamReader rdr = new StreamReader(pipe, Encoding.Unicode))
    {
        System.Console.WriteLine("Message from Server: " + rdr.ReadToEnd());
    }

    Console.ReadKey();
}

我还注意到，C++ Server我必须更改PIPE_TYPE to BYTEand READMODE to BYTE。我正在使用OpenCV libraryforImage Processing所以我可以很容易地Byte Array解决这个问题。

那么，任何人都可以告诉我如何将它Byte Array从发送C++到C#。或者如果可能的话，任何人都可以为我提供代码

提前致谢

更新： 没有错误出现，但在客户端，即C# Side来自服务器的消息的输出是????? .

标签： c#c++opencvipcnamed-pipes

解决方案

要将字节数组从 发送Server到Client即需要对函数进行buffer微小的更改。WriteFile

WriteFile(hPipe, buffer, sizeof(buffer) * sizeof(uchar), &bytesWritten, NULL);

此方法会将整个发送Byte Array到Client 并且还会更改buffer

int _count = 0;
UINT8 _imageBuffer[110592];
for (int _imageRow = 0; _imageRow < _image.rows; _imageRow++)
{
    for (int _imageCol = 0; _imageCol < _image.cols; _imageCol++)
    {
        buffer[_count] = image.at<uchar>(_imageRow, _imageCol);
        _count++;
    }
}

我对缓冲区数组进行了硬编码，因为我知道我的相机只会发送110592字节来创建一帧。

而在客户端只需使用Read功能。

            int _imageRowSize = 288;
            int _imageColSize = 384;
            int _count = 0;
            byte[] buffer = new byte[_imageColSize * _imageRowSize];
            Image<Gray, UInt16> image = new Image<Gray, UInt16>(_imageColSize,_imageRowSize);
            Console.WriteLine("Creating Client Pipe");
            NamedPipeClientStream pipe = new NamedPipeClientStream(".", "HyperPipe", PipeDirection.InOut);
            Console.WriteLine("Pipe Created Successfully, Connecting to Server");
            pipe.Connect();
            Console.WriteLine("Successfully, Connected to Server");
            using (MemoryStream ms = new MemoryStream())
            {
                while (true)
                {
                    _count = 0;      
                    int read = pipe.Read(buffer, 0, buffer.Length);
                    for (int _imageRow = 0; _imageRow < 288; _imageRow++)
                    {
                        for (int _imageCol = 0; _imageCol < 384; _imageCol++)
                        {
                            try
                            {
                                image.Data[_imageRow, _imageCol, 0] = (UInt16)(buffer[_count] * 255);
                            }catch(Exception exception)
                            {
                                Console.WriteLine(exception);
                            }
                            _count++;
                        }
                    }
                    if (read <= 0)
                        break;
                    ms.Write(buffer, 0, read);
                }
            }           
            CvInvoke.Imshow("Image", image);
        }

推荐阅读