BS1051-基于C#+udp协议实现局域网内即时通信程序

{

    public event RecevieMessageHandler RecevieMessage;

    UdpStatus status = UdpStatus.Close;

    IPAddress listenIp;

    int listenPort;

    UdpClient udpClient;

    IPEndPoint remotePoint;

    bool work = true;

    public UdpServer(IPAddress hostIp, int hostPort)

    {

        listenIp = hostIp;

        listenPort = hostPort;

        udpClient = new UdpClient(new IPEndPoint(listenIp, listenPort));

    }

    public void Start()

    {

        if (work)

        {

            status = UdpStatus.Open;

            udpClient.BeginReceive(ReceiveCallback, udpClient);

        }

    }

    private void ReceiveCallback(IAsyncResult ar)

    {

        var client = ar.AsyncState as UdpClient;

        try

        {

            byte[] data = client.EndReceive(ar, ref remotePoint);

            MessageEventArg e = new MessageEventArg();

            e.message = new Message();

            e.message.Deserialize(data);

            e.requestIp = remotePoint.Address.ToString();

            e.requestPort = remotePoint.Port;

            if (RecevieMessage != null)

            {

                RecevieMessage(this, e);

            }

        }

        catch (Exception)

        {

            Stop();

        }

        Start();

    }

    public void Stop()

    {

        work = false;

        udpClient.Close();

        status = UdpStatus.Close;

    }

}