2

我正在处理 ac# 和 php 项目，其中 PHP 脚本打开一个到 ac# 程序的套接字，c# 程序将读取数据，然后发回响应。

在 PHP 脚本中，我有以下内容：

echo "Opening Client";

$fp = fsockopen("127.0.0.1", 12345, $errno, $errstr, 30);

if (!$fp)
{
    echo "Error: $errstr ($errno)<br />";
}
else
{
    $out = "GET / HTTP/1.1\r\n";
    $out .= "Host: 127.0.0.1\r\n";
    $out .= "Connection: Close\r\n\r\n";
    fwrite($fp, $out);
    while (!feof($fp))
    {
        echo fgets($fp, 128);
    }
    fclose($fp);
}

在 C# 项目中，我有以下内容：

public void startListen()
        {
            int port = 12345;
            IPAddress serverAddress = IPAddress.Parse("127.0.0.1");
            TcpListener listener = new TcpListener(serverAddress, 12345);
            listener.Start();

            TcpClient client = listener.AcceptTcpClient();

            NetworkStream stream = client.GetStream();
            byte[] data = new byte[client.ReceiveBufferSize];
            int bytesRead = stream.Read(data, 0, Convert.ToInt32(client.ReceiveBufferSize));
            string request = Encoding.ASCII.GetString(data, 0, bytesRead);
            Console.WriteLine(request);

            Console.ReadLine();

PHP 脚本似乎一直在等待并且没有完成，我猜它是因为 c# 应用程序上的套接字发送回响应，但我不知道该怎么做。另一个问题，在 C# 中我需要有，Console.ReadLine()否则 c# 程序将退出，但 PHP 脚本会按预期完成。

基本上，我想知道的是这是读取在套接字上发送的数据的最佳方式，保持程序运行以便它继续侦听套接字的最佳方式是什么，以及我如何发回回复以便php脚本可以完成。

感谢您的任何帮助，您可以提供。

4

3 回答 3

5

我设法弄清楚了这一点，在处理完数据后我需要发送一个 stream.write ，这就是发送回复的内容。

下面是代码

            int port = 12345;
            IPAddress serverAddress = IPAddress.Parse("127.0.0.1");
            TcpListener listener = new TcpListener(serverAddress, port);
            listener.Start();

            while (true)
            {
                TcpClient client = listener.AcceptTcpClient();

                NetworkStream stream = client.GetStream();
                byte[] data = new byte[client.ReceiveBufferSize];
                int bytesRead = stream.Read(data, 0, Convert.ToInt32(client.ReceiveBufferSize));
                string request = Encoding.ASCII.GetString(data, 0, bytesRead);
                Console.WriteLine(request);
                byte[] msg = System.Text.Encoding.ASCII.GetBytes("200 OK");

                // Send back a response.
                stream.Write(msg, 0, msg.Length);
                client.Close();
            }

谢谢你的帮助

于 2012-05-29T22:50:03.557 回答
2

Boardy 先生的解决方案是正确的，但我认为通过套接字这样做会更好。

所以socket解决方案是：

private void Form3_Load(object sender, EventArgs e)
{
    sc_listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
    IPEndPoint ip_local = new IPEndPoint(IPAddress.Loopback, 1225);
    sc_listener.Bind(ip_local);
    sc_listener.Listen(10);

    AsyncCallback callback = new AsyncCallback(procces_incoming_socket);
    sc_listener.BeginAccept(callback, sc_listener);
}

void procces_incoming_socket(IAsyncResult socket_object)
{
    Socket sc_listener = ((Socket)socket_object.AsyncState).EndAccept(socket_object);

    AsyncCallback receive = new AsyncCallback(receive_data);
    buffer = new byte[100];
    sc_listener.BeginReceive(buffer, 0, buffer.Length, SocketFlags.None, receive, sc_listener);
}

void receive_data(IAsyncResult socket)
{
    // the system need to wait so i make a loop when it gets data 
    //i end the loop by flag=false
    bool flag = true;
    Socket re_socket = ((Socket)socket.AsyncState);
    while(flag)
    {
        int bytes_recieved = re_socket.EndReceive(socket);

        string data = UTF8Encoding.UTF8.GetString(buffer);
        if (textBox1.InvokeRequired)
        {
            // for cross thread problem
            textBox1.Invoke(new MethodInvoker(delegate { textBox1.Text = data; }));
        }
        else
        {
            textBox1.Text = data;
        }
        flag = false;
    }
    string back_data = "my pm socket back";
    byte[] buffers = new byte[50];
    buffers = UTF8Encoding.UTF8.GetBytes(back_data);
    re_socket.Send(buffers);
    // if the socket is not closed php will load for maximum required time and then error
    re_socket.Close();
    //start for next listening (O-0)
    AsyncCallback callback = new AsyncCallback(procces_incoming_socket);
    sc_listener.BeginAccept(callback, sc_listener);
}
于 2015-09-25T01:41:20.553 回答
0

无论如何，我都不是一个 php 人，所以我的答案取决于 php 是否能够正确响应。在 C# 端，创建一个 while/do-while 循环，该循环继续运行以接受下一个传入请求。这是一个简单的例子：

http://www.csharp-examples.net/socket-send-receive/

确保设置 NoDelay 选项，以便刷新信息。

于 2012-05-29T21:06:50.307 回答