Nicht-Blockierung von UDP-Client-Erhalten-Thread-Safe Call

Bin ich auf der Suche nach einer Lösung für dieses problem, für das Alter. Ich habe versucht, viele Dinge, einschließlich BeginReceive(), aber alles ohne Erfolg. Es muss ein Weg, um dies zu tun, stellen Sie ein UDP-Client receive-Aufruf ist nicht blockierend UND thread-safe. Ich bin versucht, eine Nachricht erhalten, und schreiben Sie es auf ein Rich-Text-Feld.

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.Threading;
using System.IO;

namespace Chat
{
    public partial class Form1 : Form
    {
        public bool contfunctioning = true; public bool changedsplay = false;
        public string enteredchats, msg, chatstring, Chats;

        UdpClient subscriber = new UdpClient(8899);
        UdpClient publisher = new UdpClient("230.0.0.100", 8898);


        public Form1()
        {
            InitializeComponent();
        }


        private void btnConnect_Click(object sender, EventArgs e)
        {

            string ConnectIPAddress;
            ConnectIPAddress = txtboxIP.Text;
            IPAddress addr = IPAddress.Parse(ConnectIPAddress);

            MessageBox.Show("Subscribing to chat server on " + ConnectIPAddress + ".", ConnectIPAddress);

            EndPoint ep = null;

            //This is where The UDPClient subscriber needs to Begin.Receive()


        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            enteredchats = txtboxUsr.Text + " " + txtboxentertxt.Text;
            txtboxentertxt.Clear();

            msg = String.Format(enteredchats);
            sdata = Encoding.ASCII.GetBytes(msg);
            publisher.Send(sdata, sdata.Length);
        }

    }
}

Genug code, ja?
Vielen Dank im Voraus für alle Antworten.

  • Wie haben Sie versucht BeginReceive? Es ist thread-safe, wenn Sie es richtig zu verwenden.
  • Welches problem haben Sie genau? Mit BeginReceive perfekt funktionieren würde hier.
  • Liegt es an mir oder funktioniert der Codeausschnitt enthalten BeginReceive irgendwo?
  • Es enthält nicht BeginReceive(), wie ich bereits in meiner Frage, ich habe es versucht und es hat nicht funktioniert. Die tutorials die ich gefunden habe waren nicht sehr beschreibend, wenn jemand mir zeigen könnte, in eine Antwort, wie es in diesem Fall, dass würde sehr geschätzt werden.
InformationsquelleAutor Bloodyaugust | 2010-01-18
  1. 2

    Ich fand, dass mit einem Timer() erlaubt mir, dieses problem zu umgehen.

    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;
using System.Diagnostics;


namespace Chat
{
    public partial class Form1 : Form
    {


        public bool contfunctioning = true; public bool changedsplay = false; public bool setupntwrk = false;
        public string enteredchats, msg, chatstring, Chats, lastchatstring;

        UdpClient subscriber = new UdpClient(8899);
        UdpClient publisher = new UdpClient("230.0.0.100", 8898);

        System.Windows.Forms.Timer timer1use = new System.Windows.Forms.Timer();



        public Form1()
        {
            InitializeComponent();
        }



        private void btnConnect_Click(object sender, EventArgs e)
        {
            Thread rcvchats = new Thread(ReceiveChats);
            rcvchats.Start();

            timer1use.Interval = 1000;
            timer1use.Start();
        }

        private void btnSend_Click(object sender, EventArgs e)
        {
            enteredchats = txtboxUsr.Text + ": " + txtboxentertxt.Text;
            txtboxentertxt.Clear();

            msg = String.Format(enteredchats);
            byte[] sdata = Encoding.ASCII.GetBytes(msg);
            publisher.Send(sdata, sdata.Length);
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            if (chatstring != lastchatstring)
            dsplay.AppendText("\r\n" + chatstring);

            lastchatstring = chatstring;


        }

        public void ReceiveChats()
        {
            while (true)
            {
                if (setupntwrk == false)
                {
                    string ConnectIPAddress;
                    ConnectIPAddress = txtboxIP.Text;
                    IPAddress addr = IPAddress.Parse(ConnectIPAddress);
                    MessageBox.Show("Subscribing to chat server on " + ConnectIPAddress + ".", ConnectIPAddress);
                    subscriber.JoinMulticastGroup(addr);

                    setupntwrk = true;
                }

                IPEndPoint ep = null;
                chatstring = Encoding.ASCII.GetString(subscriber.Receive(ref ep));

                Thread.Sleep(1000);
            }

        }

        private void btnHost_Click(object sender, EventArgs e)
        {
            Process starthost = new Process();
            starthost.StartInfo.FileName = "C:\\ChatServ.exe";
            starthost.Start();

        }
    }
}
    • Wieso der downvote? Seine rechtliche Beantwortung meiner eigenen Frage, in der Tat, es geschieht, um ein badge für Sie.
    InformationsquelleAutor Bloodyaugust
Schreibe einen Kommentar