WPF 聊天应用程序帮助 C#答案

【问题标题】：WPF Chat application help C#WPF 聊天应用程序帮助 C#
【发布时间】：2013-10-04 01:48:39
【问题描述】：

我需要一些关于使用套接字的 WPF 聊天应用程序的帮助。问题是它似乎不起作用，所以有人可以指导我做错了什么。下面你会在代码WPF代码后面找到我的代码：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using System.Windows.Controls;
using System.Windows.Data;
using System.Windows.Documents;
using System.Windows.Input;
using System.Windows.Media;
using System.Windows.Media.Imaging;
using System.Windows.Navigation;
using System.Windows.Shapes;
using System.Net;
using System.Net.Sockets;
using System.Windows.Threading;

namespace CSSChat
{
    /// <summary>
    /// Interaction logic for MainWindow.xaml
    /// </summary>
    public partial class MainWindow : Window
    {
        public Socket sck = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);

        public MainWindow()
        {
            InitializeComponent();
            sck.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);

            textLocalIp.Text = GetLocalIP();
            textRemoteIp.Text = GetLocalIP();
        }

        //return own IP
        private string GetLocalIP()
        {
            string ipaddr = null;

            IPHostEntry host;
            host = Dns.GetHostEntry(Dns.GetHostName());
            foreach (IPAddress ip in host.AddressList)
            {
                if (ip.AddressFamily == AddressFamily.InterNetwork)
                {
                    ipaddr = ip.ToString();
                    return ipaddr;
                }
            }

            //in case we didn't get it
            if (ipaddr == null) throw new ArgumentNullException("IP can not be null in GetLocalIP() ");
            return "127.0.0.1";
        }

        private void MessageCallBack(IAsyncResult ar)
        {
            try
            {
                EndPoint epRemote = new IPEndPoint(IPAddress.Parse(textRemoteIp.Text), Convert.ToInt32(textRemotePort.Text));
                int size = sck.EndReceiveFrom(ar, ref epRemote);

                //check if we got something
                byte[] recvdata = new byte[1464];
                recvdata = (byte[])ar.AsyncState;

                //convert to human-readable
                ASCIIEncoding enc = new ASCIIEncoding();
                string recv_message = enc.GetString(recvdata);

                //adding message to the listbox
                this.Dispatcher.Invoke((Action)(() =>
                {
                    listMessages.Text += "Remote box: " + recv_message;
                    listMessages.Text += "\r\n";
                }));
            //start listening again
            byte[] buf = new byte[1500];
            sck.BeginReceiveFrom(buf, 0, buf.Length, SocketFlags.None, ref epRemote, new AsyncCallback(MessageCallBack), buf);
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }

        private void btnStart_Click_1(object sender, RoutedEventArgs e)
        {
            {
                //bind socket
                try
                {
                    this.Dispatcher.Invoke((Action)(() =>
                    {
                        EndPoint eplocal = new IPEndPoint(IPAddress.Parse(textLocalIp.Text), Convert.ToInt32(textLocalPort.Text));
                        sck.Bind(eplocal);

                        //connect to remote IP & Port
                        EndPoint epRemote = new IPEndPoint(IPAddress.Parse(textRemoteIp.Text), Convert.ToInt32(textRemotePort.Text));
                        sck.Connect(epRemote);

                        //start listening
                        byte[] buf = new byte[1500];
                        sck.BeginReceiveFrom(buf, 0, buf.Length, SocketFlags.None, ref epRemote, new AsyncCallback(MessageCallBack), buf);

                        //send
                        btnStart.Content = "Connected";
                        btnStart.IsEnabled = false;
                        textMessage.Focus();
                    }));
                }
                catch (Exception ex)
                {
                    MessageBox.Show(ex.ToString());
                }
            }
        }

        private void btnSend_Click_1(object sender, RoutedEventArgs e)
        {
            try
            {
                this.Dispatcher.Invoke((Action)(() =>
                {
                //convert to human-readable 
                ASCIIEncoding enc = new ASCIIEncoding();
                byte[] buf = new byte[1500];
                buf = enc.GetBytes(textMessage.Text);

                //send message
                sck.Send(buf);

                //add to chat window
                    listMessages.Text += "Me: " + textMessage.Text;
                    listMessages.Text += "\r\n";

                    //clear
                    textMessage.Clear();
                }));
            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString());
            }
        }
    }
}

任何反馈都将不胜感激，谢谢！

【问题讨论】：

您是否收到任何错误消息？你能把代码缩小到有问题的部分吗？
您好，应用程序编译顺利，没有任何错误。我只是在这里迷路了，一切似乎都完好无损，但是当我使用本地计算机上的两个实例或两台不同的笔记本电脑上测试它时，它不会在远程计算机上发送或接收消息。
两台机器在同一个子网上？
嗨，是的。我尝试使用本地 IP 和远程 IP 并重定向路由器上的相应端口。
路由器上的端口重定向仅适用于内存服务的外部流量。在内部子网上，您的路由器不会为重定向而烦恼。这可能不是您的问题，但如果您希望重定向到另一个端口，则可能是失败。另外，请确保open up your port in Windows Firewall

标签： c# wpf windows sockets chat

【解决方案1】：

解决方案是使用调用程序并将所有事件放入其中一个

    this.Dispatcher.Invoke(new Action(() =>
{
... your code here ...
}));

或

//for asynchronous multithreading
this.Dispatcher.BeginInvoke(DispatcherPriority.Normal, new ThreadsTart(() =>
{
...
}));

在上面的代码中都这样做了。

【讨论】：