talker.cs

C常用算法程序集,一部比较经典的程序算法合集

using System;
using System.Collections.Generic;
using System.Text;
using System.Net;

namespace mychat1
{
  public class Talker
    {
        private IMessageReceiver receiver;
        private IMessageSender sender;


        public Talker()
        {
        }
        public Talker(string myownip)
        {
            this.receiver = new MessageReceiver(myownip);
            this.sender = new MessageSender();
        }

        public event MessageReceivedEventHandler MessageReceived
        {
            add
            {
                receiver.MessageReceived += value;
              
            }
            remove
            {
                receiver.MessageReceived -= value;
   
            }
        }

      public event MessageReceivedEventHandler ServerMessageReceived
      {
          add
          {
             sender.MessageReceived += value;

          }
          remove
          {
              sender.MessageReceived -= value;


          }
      }

        public event ClientConnectedEventHandler ClientConnected
        {
            add
            {
                receiver.ClientConnected += value;
            }
            remove
            {
                receiver.ClientConnected -= value;
            }
        }

        public event ConnectionLostEventHandler ClientLost
        {
            add
            {
                receiver.ClientLost += value;
            }
            remove
            {
                receiver.ClientLost -= value;
            }
        }

        // 注意这个事件
      /*  public event PortNumberReadyEventHandler PortNumberReady
        {
            add
            {
                ((MessageReceiver)receiver).PortNumberReady += value;
            }
            remove
            {
                ((MessageReceiver)receiver).PortNumberReady -= value;
            }
        }*/
       
        // 连接远程 - 使用IP
        public bool ConnectByIp(string ip, int port)
        {
            IPAddress ipAddress;
            try
            {
                ipAddress = IPAddress.Parse(ip);
            }
            catch
            {
                return false;
            }
            return sender.Connect(ipAddress, port);
        }


        // 发送消息
        public bool SendMessage(Message msg,int i)
        {
            if (i == 1)
                return receiver.SendMessage(msg);
            else 
                return sender.SendMessage(msg);
        }

        


        // 释放资源，停止侦听
        public void Dispose()
        {
            try
            {
                sender.SignOut();//把和对方有关的连接断开
                receiver.StopListen();
            }
            catch
            {
            }
        }

        // 注销
        public void SignOut()
        {
            try
            {
                sender.SignOut();
            }
            catch
            {
            }
        }

    }
}