首頁 > 後端開發 > Golang > 主體

如何在go和c#控制台應用程式之間建立長期管道連接

WBOY
發布: 2024-02-13 22:50:08
轉載
927 人瀏覽過

如何在go和c#控制台應用程式之間建立長期管道連接

php小编新一为您介绍如何在Go和C#控制台应用程序之间建立长期管道连接。在开发跨平台应用程序时,Go和C#是两种常用的编程语言。建立管道连接可以实现两种语言之间的通信和数据交换。本文将介绍如何使用Go和C#的相关库和API来建立稳定、可靠的长期管道连接,以便实现数据的传输和交互。无论您是Go开发者还是C#开发者,通过本文的指导,您都可以轻松地在两种语言之间建立管道连接,实现应用程序的功能需求。

问题内容

我有非常简单的 C# 控制台应用程序。这将是一个添加从 go 部分传递的 double 变量的过程。

double sum = 0;
bool flag = true;

while(flag) {  // exit on convert error
    var str = Console.ReadLine(); // ask string 

    double addend;
    flag = double.TryParse(str, out addend); // convert to double

    sum += flag ? addend : 0;  //add on success
    Console.WriteLine(sum);
}

return 0;
登入後複製

我的 go 部分也很简单。它使用以前的控制台应用程序创建进程,向其发送字符串并读回结果。

package main

import (
    "fmt"
    "io"
    "log"
    "os/exec"
)

func main() {

    cmd := exec.Command("%path to app%\\ConsoleApp.exe") // process that will be started
    
stdout, err := cmd.StdoutPipe() // use std out pipe
    if err != nil {
        log.Fatal(err)
    }

    stdin, err := cmd.StdinPipe() // use std in pipe
    if err != nil {
        log.Fatal(err)
    }

    if err := cmd.Start(); err != nil { // start
        log.Fatal(err)
    }

    for true {
        var w1 string
        _, err := fmt.Scanln(&w1) // read line

        if err != nil {
            log.Fatal()
        }

        go func() {
            io.WriteString(stdin, w1) // pass it to console app
        }()

        read, err := io.ReadAll(stdout) // read result

        fmt.Println(read)

        if err != nil {
            log.Fatal()
        }
    }
}
登入後複製

我开始调试控制台应用程序的进程(它出现在任务管理器、RMC - 调试中),但存在符号错误,所以我什至无法理解我的应用程序是否获取了字符串。

这只是我的麻烦的一半。我认为我的控制台应用程序有一两次收到字符串(我的意思是以前的时间),但只有第一个,导致管道在传输/复制后关闭。那么我该如何控制呢?我想要执行多个事务、写入和读取,并仅在需要时关闭管道。

编辑:我对 ConsoleApp 做了一些更改。现在看起来像这样:

double sum = 0;
bool flag = true;
while(flag) {
    var str = Console.ReadLine();
    double addend;
    flag = double.TryParse(str, out addend);

    // File creation will indicate that message was recieved. 
    using(StreamWriter writer = new StreamWriter("t.txt")) { 
        writer.WriteLine($"{flag}");
    }

    sum += flag ? addend : 0;
    Console.WriteLine(sum);
}

return 0;
登入後複製

解决方法

所以,@maxm 非常接近(或者甚至已经找到了解决方案,但它对我不起作用,fsr)。

执行部分:

package main

import (
    "bufio"
    "fmt"
    "log"

    "os/exec"
)

func main() {
    cmd := exec.Command("%path to the exe%")

    stdout, err := cmd.StdoutPipe() 
    if err != nil {
        log.Fatal(err)
    }

    stderr, err := cmd.StderrPipe()
    if err != nil {
        log.Fatal(err)
    }

    scanner := bufio.NewScanner(stdout)

    stdin, err := cmd.StdinPipe()
    if err != nil {
        log.Fatal(err)
    }

    if err := cmd.Start(); err != nil {
        log.Fatal(err)
    }

    for {
        var w1 string
        _, err := fmt.Scanln(&w1)
        w2 := []byte(w1) // important! You need convert string to byte array

        if err != nil {
            log.Fatal()
        }

        if _, err := stdin.Write(w2); err != nil { // pass byte array
            log.Fatal(stderr)
            panic(err)
        } 

        if scanner.Scan() {
            read := scanner.Text()
            fmt.Println(read)
        } else {
            if err := scanner.Err(); err != nil {
                panic(err)
            }
        }
    }
}
登入後複製

C# 部分非常简单。首先,您需要从字节数组恢复字符串:

public static string ByteArrayToString(this byte[] byteArray, int size) {
    // get decoder to decode input encoding
    var decoder = Console.InputEncoding.GetDecoder(); 

    // count char that will be restored
    int charCount = decoder.GetCharCount(byteArray, 0, size);

    // initialize char array
    char[] charArray = new char[charCount];
    // restore to char array
    decoder.GetChars(byteArray, 0, size, charArray, 0);

    // get and return string from our char array
    return new string(charArray);
}
登入後複製

接下来是主要部分:

double sum = 0;
bool flag = true;
while(flag) {
    string str;

    using Stream stdin = Console.OpenStandardInput(); // for reading 

    byte[] buffer = new byte[2048];
    int bytes = 0; // bytes count

    while((bytes = stdin.Read(buffer, 0, buffer.Length)) > 0) { // read
        str = buffer.ByteArrayToString(bytes); // restore string
        flag = double.TryParse(str, out double addend);
        sum += flag ? addend : 0;
        Console.WriteLine(sum); //write

        if(!flag)
            break;
    }
}

return 0;
登入後複製

以上是如何在go和c#控制台應用程式之間建立長期管道連接的詳細內容。更多資訊請關注PHP中文網其他相關文章!

相關標籤:
來源:stackoverflow.com
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
最新問題
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板