我有非常简单的 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;
做了一些更改,正如 @Burak 指出的那样,ReadAll 将停止执行,直到进程退出,所以不要认为您想要这样。我还使用
bufio.Scanner
来阅读每一行:
// You can edit this code!
// Click here and start typing.
package main
import (
"bufio"
"fmt"
"io"
"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 {
panic(err)
}
scanner := bufio.NewScanner(stdout)
stdin, err := cmd.StdinPipe() // use std in pipe
if err != nil {
panic(err)
}
if err := cmd.Start(); err != nil { // start
panic(err)
}
for {
var w1 string
_, err := fmt.Scanln(&w1) // read line from console
if err != nil {
panic(err)
}
if _, err := io.WriteString(stdin, w1); err != nil {
panic(err)
} // pass it to console app
if scanner.Scan() {
read := scanner.Text()
fmt.Println(read)
} else {
if err := scanner.Err(); err != nil {
panic(err)
}
}
}
}
所以,@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;