0

現在、サーバーとクライアントの間でチャットのアプリケーションを実行しています。それは機能しますが、[クライアントがサーバーに送信]-> [サーバーがクライアントに再度送信]というシーケンスに従うしかありません。サーバーがそれをクライアントに送り返さなかった場合、クライアントはフリーズしたままになります。私は実際に、クライアントがこれらのシーケンスなしでサーバーに送信し続けることができるようにしたいと考えています。私が使用できる提案はありますか？バックグラウンドワーカーか何か？キープレスを試しましたが、うまく機能しません。どんな提案でも試してみます、ありがとう。
最初のコードはコンソール アプリケーションのサーバー コードで、2 番目のコードは Windows フォーム アプリケーションのクライアント コードです。

    namespace TcpIpNewServer
{
class Program
{
    static void Main(string[] args)
    {
        TcpListener serverSocket = new TcpListener(8888);
        TcpClient clientSocket = default(TcpClient);
        serverSocket.Start();
        Console.WriteLine(">> Server started...");
        clientSocket = serverSocket.AcceptTcpClient();
        Console.WriteLine(">> Accepted connection from client...");

        while ((true))
        {               
            NetworkStream networkStream = clientSocket.GetStream();                               
            byte[] bytesFrom = new byte[10025];
            networkStream.Read(bytesFrom, 0, (int)clientSocket.ReceiveBufferSize);
            if (bytesFrom[0].ToString() != "0")                                     //listen from client
            {
                string dataFromClient = System.Text.Encoding.ASCII.GetString(bytesFrom);
                dataFromClient = dataFromClient.Substring(0, dataFromClient.IndexOf("$^$~~)("));      //hardcode
                Console.WriteLine("<< Client : " + dataFromClient);
            }

            //var cki = Console.ReadKey(true);
            //if (cki.KeyChar == 't')
            //{                    
                string serverResponse = Console.ReadLine();
                if (serverResponse != null)                                         //write to client
                {
                    Byte[] sendBytes = Encoding.ASCII.GetBytes(serverResponse);
                    networkStream.Write(sendBytes, 0, sendBytes.Length);
                    networkStream.Flush();
                }
            //}
        }
    }
}
}

クライアントコード

public partial class Form1 : Form
{
    public Form1()
    {
        InitializeComponent();
    }

    private void Form1_Load(object sender, EventArgs e)
    {
        Msg("Client started...");
        try
        {
            clientSocket.Connect("127.0.0.1", 8888);
            NetworkStream serverStream = clientSocket.GetStream();
            label1.Text = "Client Socket Program - Server connected...";
        }
        catch (Exception ex)
        {
            label1.Text = "Client Socket Program - Server connection failed... Please try again...Make sure server is on...";
        }

    }

    System.Net.Sockets.TcpClient clientSocket = new System.Net.Sockets.TcpClient();

    private void button1_Click(object sender, EventArgs e)
    {

        NetworkStream serverStream = clientSocket.GetStream();
        if (textBox1.Text != "" && textBox1.Text != null)                       //write to the server
        {
            //string trimDataText = Regex.Replace(textBox1.Text, @"s", "");              
            string cloneTextbox = textBox1.Text + "$^$~~)(";
            Msg("Me: " + textBox1.Text);
            textBox1.Text = ""; 
            byte[] outStream = System.Text.Encoding.ASCII.GetBytes(cloneTextbox);
            serverStream.Write(outStream, 0, outStream.Length);
            serverStream.Flush();                
        }

        byte[] inStream = new byte[10025];                                      //read from the server
        //if (inStream[0].ToString() != "0")
        //{
            serverStream.Read(inStream, 0, (int)clientSocket.ReceiveBufferSize);
            string returndata = System.Text.Encoding.ASCII.GetString(inStream);
            Msg2("Server: " + returndata);
        //}   
    }

    private void Msg(string mesg)
    {
        richTextBox1.Text = richTextBox1.Text + Environment.NewLine + ">> " + mesg;
    }

    private void Msg2(string mesg)
    {
        richTextBox1.Text = richTextBox1.Text + Environment.NewLine + "<< " + mesg;
    }
4

1 に答える 1

0

非同期の読み取り/書き込みに切り替える必要があります。NetworkStream.BeginRead()

http://msdn.microsoft.com/en-us/library/system.net.sockets.networkstream.beginread%28v=vs.110%29.aspx

于 2014-05-19T03:27:24.607 に答える