mainform.cs

一个用C＃编写的能实现即时通讯的工具

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Threading;

using agsXMPP;
using agsXMPP.protocol.client;
using agsXMPP.protocol.iq.browse;
using agsXMPP.Xml.Dom;

namespace client
{
    public partial class mainForm : Form
    {
        private XmppClientConnection con;
        delegate void OnMessageDelegate(object sender, agsXMPP.protocol.client.Message msg);
        delegate void OnIqDelegate(object sender, Node e);
        delegate void OnPresenceDelegate(object sender, Presence pres);
        delegate void OnMeetingDelegate(object sender, Presence pres);
        static public bool Isgroupchat;
        static public bool Iscreatergroupchat;
        static public bool Islogingroupchat;
        private loading frmload;

        public mainForm()
        {
            InitializeComponent();
            con = new XmppClientConnection();
            frmload = new loading();

            Isgroupchat = false;
            Iscreatergroupchat=false;
            Islogingroupchat = false;
            con.OnReadXml += new XmlHandler(con_OnReadXml);
            con.OnWriteXml += new XmlHandler(con_OnWriteXml);
            con.OnLogin += new ObjectHandler(con_OnLogin);
            con.OnAuthError+=new OnXmppErrorHandler(con_OnAuthError);
            con.OnError += new ErrorHandler(con_OnError);

            //成员列表
            //con.OnRosterStart += new ObjectHandler(con_OnRosterStart);
            con.OnRosterItem += new agsXMPP.XmppClientConnection.RosterHandler(con_OnRosterItem);
            //con.OnRosterEnd+=new ObjectHandler(con_OnRosterEnd);
        
            //消息处理
            con.OnMessage+=new XmppClientConnection.MessageHandler(con_OnMessage);
            //出席消息
            con.OnPresence += new XmppClientConnection.PresenceHandler(con_OnPresence);
            //请求消息
            con.OnIq+=new agsXMPP.Xml.StreamHandler(con_OnIq);
            agsXMPP.Factory.ElementFactory.AddElementType("Info", "agsoftware:Info", typeof(Info));

        }

        private void connect()
        {
            con.Open();
        }

        private void mainForm_Load(object sender, EventArgs e)
        {

            login frm = new login(con);
            if (frm.ShowDialog() == DialogResult.OK)
            {
                Thread mythread = new Thread(connect);
                mythread.Start();
                frmload.ShowDialog();
            }
            else
            {
                this.Close();
                Application.Exit();
            }
        }

        private  void con_OnLogin(object sender)
        {
            //发送在线状态给其他用户
            con.Show = ShowType.chat;
            con.SendMyPresence();
            Control.CheckForIllegalCrossThreadCalls = false;
            frmload.Close();
            this.toolStripButton1.Text ="登陆用户："+con.Username+"\n"+"当前状态：在线";
        }

        private void con_OnAuthError(object sender, Element e)
        {
            MessageBox.Show("密码错误！");
            Application.Exit();
            System.Diagnostics.Process.Start("client.exe");
        }

        private void con_OnIq(object sender, Node e)
        {
            if (InvokeRequired)
            {
                // Windows Forms are not Thread Safe, we need to invoke this :(
                // We're not in the UI thread, so we need to call BeginInvoke				
                BeginInvoke(new OnIqDelegate(con_OnIq), new object[] { sender, e });
                return;
            }

            IQ iq = e as IQ;
            if (iq.Id == "loginmeeting")
            {
                if (iq.Type == IqType.result)
                {
                    groupChat frm = new groupChat(iq.From, con);
                    onlinegroupchatfrm.groupchatfrm = frm;
                    frm.Show();
                    //MessageBox.Show("登入成功！");
                }
                if (iq.Type == IqType.error)
                {
                    MessageBox.Show("密码错误！","注意");
                    Isgroupchat = false;
                }
            }
            else if (iq.HasTag(typeof(Info)))
            {
                    Info _Info = iq.SelectSingleElement(typeof(Info)) as Info;
                    if (iq.Id == "browse")
                    {
                        userInfo frm = new userInfo(_Info);
                        frm.Show();
                    }
                    if (iq.Id == "edit")
                    {
                        editUserInfo frm = new editUserInfo(_Info,this.con);
                        frm.Show();
                    }
            }
        }

        private  void con_OnError(object sender, Exception ex)
        {
            MessageBox.Show("连接服务器失败！");
            Application.Exit();
            System.Diagnostics.Process.Start("client.exe");
        }

        private  void con_OnReadXml(object sender, string xml)
        {
            Console.WriteLine("接收 XML: " + xml);
        }

        private  void con_OnWriteXml(object sender, string xml)
        {
            Console.WriteLine("发送 XML: " + xml);
        }
        //下载成员列表
        private void con_OnRosterItem(object sender, agsXMPP.protocol.iq.roster.RosterItem item)
        {
            if (InvokeRequired)
            {
                // Windows Forms are not Thread Safe, we need to invoke this :(
                // We're not in the UI thread, so we need to call BeginInvoke				
                BeginInvoke(new agsXMPP.XmppClientConnection.RosterHandler(con_OnRosterItem), new object[] { this, item });
                return;
            }
            //下载好友列表
            /*************************************************************************************
             * 2007-05-16   牛坤
             * 下载好友列表   分组名称为数节点的父节点  成员列表为数子节点
             * **********************************************************************************/
            show_usersList(item);
        }
        private void show_usersList(agsXMPP.protocol.Base.RosterItem item)
        {
            //取出Item的group属性  遍历当前树   查找匹配的分组
            //如果有    添加到该分组的子节点
            //如果没有  添加该分组  并将该用户加入该分组
            bool flag = false;
            foreach (TreeNode node in treeView1.Nodes)
            {
                node.Expand();
                if (node.Text == item.FirstChild.Value)
                {
                    TreeNode childnode = new TreeNode(item.Name);
                    node.Nodes.Add(childnode);
                    childnode.ImageIndex = Convert.ToInt32(item.Value)+100;
                    childnode.SelectedImageIndex = Convert.ToInt32(item.Value)+100;
                    flag = true;
                }
            }
            if (!flag)
            {
                TreeNode newnode = new TreeNode(item.FirstChild.Value);
                treeView1.Nodes.Add(newnode);
                newnode.ImageIndex = 0;
                newnode.SelectedImageIndex = 0;

                TreeNode childnode = new TreeNode(item.Name);
                newnode.Nodes.Add(childnode);
                childnode.ImageIndex = Convert.ToInt32(item.Value) + 100;
                childnode.SelectedImageIndex = Convert.ToInt32(item.Value) + 100;
            }
        }

        private void listView_user_MouseDoubleClick(object sender, MouseEventArgs e)
        {
            //bool check = true;
            //foreach (frmchat frm in onlinechatfrm.onlinefrm)
            //{
            //    if (frm.name == listView_user.SelectedItems[0].Text)
            //    {
            //        frm.Activate();
            //        check = false;
            //        break;
            //    }
            //}
            //if (check)
            //{
            //    frmchat frm = new frmchat(listView_user.SelectedItems[0].Text, this.con);
            //    onlinechatfrm.onlinefrm.Add(frm);
            //    frm.Show();
            //}
           
        }
        
        private void con_OnMessage(object sender, agsXMPP.protocol.client.Message msg)
        {
            if (InvokeRequired)
            {
                // Windows Forms are not Thread Safe, we need to invoke this :(
                // We're not in the UI thread, so we need to call BeginInvoke				
                BeginInvoke(new OnMessageDelegate(con_OnMessage), new object[] { sender, msg });
                return;
            }
            //处理用户点对点聊天信息
            if (msg.Type == MessageType.chat)
            {
                bool check = true;
                foreach (frmchat frm in onlinechatfrm.onlinefrm)
                {
                    if (msg.From.User == frm.name)
                    {
                        check = false;
                        Control.CheckForIllegalCrossThreadCalls = false;

                        frm.rtb_recv.SelectionFont = new Font(frm.rtb_recv.SelectionFont.FontFamily, 9);
                        frm.rtb_recv.SelectionIndent = 5;
                        frm.rtb_recv.SelectionColor = Color.Blue;
                        frm.rtb_recv.AppendText(msg.From.User + " "+ System.DateTime.Now.Hour.ToString() + ":" + System.DateTime.Now.Minute.ToString() + ":" + System.DateTime.Now.Second.ToString() + "\r\n");

                        frm.rtb_recv.SelectionFont = new Font(frm.rtb_recv.SelectionFont.FontFamily, 12);
                        frm.rtb_recv.SelectionIndent = 20;
                        frm.rtb_recv.SelectionColor = Color.Black;
                        frm.rtb_recv.AppendText(msg.Body + "\r\n");