C# 客户端应用程序不会从 Linux TCP 服务器接收消息

本文关键字:服务器 TCP 消息 Linux 客户端 应用程序 | 更新日期: 2023-09-27 18:37:15

>情况:1. LinuxTCP服务器2 视窗 C# 客户端应用程序

服务器从客户端接收消息,

但是当我尝试将消息从服务器发送到客户端时,没有任何反应。断开连接时出现错误:

"无法从传输连接读取数据:阻塞操作被对 WSACancelBlockingCall 的调用中断",它指向字符串 Response = swRead.ReadLine() --->行;

下面是客户端代码:

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.IO;
using System.Threading;
namespace AsynClient
{
    public partial class Form1 : Form
    {
        private TcpClient client;
        private StreamWriter swSend;
        private StreamReader swRead;
        private bool connected = false;
        string bojaTekst = "", bojaPoz = "";

        private delegate void UpdateLogCallback(string strMessage);
        private Thread thrMessag;
        public Form1()
        {
            Application.ApplicationExit += new EventHandler(OnApplicationExit);
            InitializeComponent();
      }
        private void btnConnect_Click(object sender, EventArgs e)
        {
            if (connected == false)
            {
                InitializeConnection();
            }
            else
                MessageBox.Show("Vec je uspostavljenja konekcija.");
        }

        private void InitializeConnection()
        {
            client = new TcpClient();
            client.Connect("192.168.100.82", 3456);
            swSend = new StreamWriter(client.GetStream()); //prvo mora da se             konektuje, pa onda ova komanda

            thrMessag = new Thread(new ThreadStart(ReceiveMessages));
            thrMessag.Start();
            connected = true;
            btnSend.Enabled = true;
            btnDisconnect.Enabled = true;
            txtMsg.Enabled = true;
            btnConnect.Enabled = false;
        }
        private void UpdateLog(string strMessage)
        {
            txtServ.AppendText(strMessage + "'r'n");
        }
        private void ReceiveMessages()
        {
            swRead = new StreamReader(client.GetStream());
            string Response = swRead.ReadLine();
            while (connected)
            {
                // Show the messages in the log TextBox
                this.Invoke(new UpdateLogCallback(this.UpdateLog), new object[] {         swRead.ReadLine() });
            }
        }
        private void btnSend_Click(object sender, EventArgs e)
        {
            if (listBoxTekst.SelectedIndex == -1)
                listBoxTekst.SelectedIndex = 0;
            if (listBoxPozadina.SelectedIndex == -1)
                listBoxPozadina.SelectedIndex = 0;
            bojaTekst = listBoxTekst.Text;
        bojaPoz = listBoxPozadina.Text;

        SendMessage();
    }
    private void SendMessage()
    {
     txtMsg.Text);
        if (txtMsg.Lines.Length >= 1)
        {
            swSend.WriteLine(bojaPoz + "'t" + bojaTekst + "'t" + txtMsg.Text + "'t"); 
            swSend.Flush();                     
            txtMsg.Lines = null;                
        }                                       
        txtMsg.Text = "";
    }
    private void btnDisconnect_Click(object sender, EventArgs e)
    {
        char[] quit = new char[5];
        quit[0] = 'q'; quit[1] = 'w'; quit[2] = 'w'; quit[3] = 'w'; quit[4] = ''0';
        connected = false;
        btnConnect.Enabled = true;
        btnSend.Enabled = false;
        btnDisconnect.Enabled = false;
        txtMsg.Enabled = false;
        swSend.WriteLine(quit);
        swSend.Flush();
        swSend.Close();
        client.Close();
    }
    public void OnApplicationExit(object sender, EventArgs e)
    {
        if (connected == true)
        {
            connected = false;
            swSend.WriteLine("qwww"); //proveri da li radi f-ja kako treba
            swSend.Flush();
            swSend.Close();
            client.Close();
        }
    }      
}

}

服务器端使用 read() 函数接收消息并且工作正常,但是当它使用 write() 发送时,C# 客户端不会收到消息。

C# 客户端应用程序不会从 Linux TCP 服务器接收消息

只有一件事(可能还有其他问题):您有一个 connected 变量,您在启动侦听线程后将其值设置为 true 。线程中的循环甚至不会运行一次。


thrMessag = new Thread(new ThreadStart(ReceiveMessages));   
thrMessag.Start();              
connected = true; //here is your first bug, should come before the previos line