C# socket 完整聊天实例源码

【实例截图】

【核心代码】

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using cn.com.simpleness.NetSocket;
using cn.com.simpleness.NetSocket.clnt;
using cn.com.simpleness.SocketDataStruct;
using cn.com.simpleness.Util;
using System.Collections.Specialized;

namespace cn.com.simpleness.SocketClientDemo
{
    public partial class ClientWinMain : Form
    {
        private ClntSocket _clntSocket = null;
        public ClientWinMain()
        {
            InitializeComponent();
        }
        private void btn_conn_server_Click(object sender, EventArgs e)
        {
            string ip = this.txt_ip.Text.Trim();
            this._clntSocket = new ClntSocket(ip, 8989);
            this._clntSocket.Connected  = new NetEventHandler(_clntSocket_Connected);
            this._clntSocket.ConntentFailed  = new NetEventHandler(_clntSocket_ConntentFailed);
            this._clntSocket.LoginSuccessed  = new NetEventHandler(_clntSocket_LoginSuccessed);
            this._clntSocket.LoginFailed  = new NetEventHandler(_clntSocket_LoginFailed);
            this._clntSocket.RecvUserList  = new NetEventHandler(_clntSocket_RecvUserList);
            this._clntSocket.RecvMessage  = new NetEventHandler(_clntSocket_RecvMessage);
            this._clntSocket.ServerClosed  = new NetEventHandler(_clntSocket_ServerClosed);
            this._clntSocket.UserLogout  = new NetEventHandler(_clntSocket_UserLogout);
            this._clntSocket.StartConn();
        }

        void _clntSocket_UserLogout(object sender, NetEventArgs e)
        {
            //用户注销
            this.txt_username.Enabled = true;
            this.txt_pwd.Enabled = true;
            this.btn_login.Enabled = true;
            this.btn_logout.Enabled = false;
            this.gb_msg.Enabled = false;
        }

        /// <summary>
        /// 接收到信息
        /// </summary>
        /// <param name="sender">this._clntSocket对象</param>
        /// <param name="e">MsgData对象</param>
        void _clntSocket_RecvMessage(object sender, NetEventArgs e)
        {
            MsgData msgData = (MsgData)e.EventArg;
            if (msgData.IsBroadcast)
            {
                if (this._clntSocket.UserData.UserName == msgData.Sender)
                    this.txt_msg_list.AppendText("[我]对[所有人]说："   msgData.Msg   "\r\n");
                else
                    this.txt_msg_list.AppendText("["   msgData.Sender   "]对[所有人]说："   msgData.Msg   "\r\n");
            }
            else
                this.txt_msg_list.AppendText("["   msgData.Sender   "]对[你]说："   msgData.Msg   "\r\n");
        }
        /// <summary>
        /// 取得用户列表
        /// </summary>
        /// <param name="sender">this._clntSocket对象</param>
        /// <param name="e">用户列表e.EventArg 是 StringCollection</param>
        void _clntSocket_RecvUserList(object sender, NetEventArgs e)
        {
            StringCollection userList = (StringCollection)e.EventArg;
            this.cbb_user_list.Items.Clear();
            foreach (string tmp in userList)
            {
                if(this._clntSocket.UserData.UserName != tmp)//不把自己的名字加入列表
                    cbb_user_list.Items.Add(tmp);
            }
            if (this.cbb_user_list.Items.Count > 0)
                this.cbb_user_list.SelectedIndex = 0;
            else
                this.cbb_user_list.Update();
        }

        void _clntSocket_LoginFailed(object sender, NetEventArgs e)
        {
            MessageBox.Show(e.EventArg.ToString());//简单显示一下信息
        }

        void _clntSocket_ServerClosed(object sender, NetEventArgs e)
        {
            //服务器关闭回调
            MessageBox.Show(e.EventArg.ToString());
        }

        void _clntSocket_LoginSuccessed(object sender, NetEventArgs e)
        {
            //登录成功
            this.txt_username.Enabled = false;
            this.txt_pwd.Enabled = false;
            this.btn_login.Enabled = false;
            this.btn_logout.Enabled = true;
            this.gb_msg.Enabled = true;
        }

        void _clntSocket_ConntentFailed(object sender, NetEventArgs e)
        {
            MessageBox.Show("链接失败！");
        }

        void _clntSocket_Connected(object sender, NetEventArgs e)
        {
            //连接成功对一系列的空间进行设置
            this.btn_conn_server.Enabled = false;
            this.btn_dis_conn.Enabled = true;
            this.gb_login.Enabled = true;
        }

        private void btn_dis_conn_Click(object sender, EventArgs e)
        {
            if (_clntSocket != null)
                _clntSocket.Stop();

            this.btn_conn_server.Enabled = true;
            this.btn_dis_conn.Enabled = false;
            this.gb_login.Enabled = false;
            this.gb_msg.Enabled = false;


            this.txt_username.Enabled = true;
            this.txt_pwd.Enabled = true;
            this.btn_login.Enabled = true;
            this.btn_logout.Enabled = false;
        }
        private void btn_login_Click(object sender, EventArgs e)
        {
            if (this._clntSocket != null)
            {
                PacketHeaderStruct phs = new PacketHeaderStruct();
                phs.type = StructConfig.GetHeaderIndexByType(HeaderType.UserLogin);
                UserData ud = new UserData();
                ud.UserName = this.txt_username.Text.Trim();
                ud.UserPwd = this.txt_pwd.Text;//密码可能有空格，所以不做缩空处理
                byte[] data = SerializeTools.ObjSerialize(ud);
                phs.length = data.Length;
                this._clntSocket.Send(phs);
                this._clntSocket.Send(data);
                //保存用户
                this._clntSocket.UserData = ud;
            }
            else
            {
                MessageBox.Show("clntSocket 空");
            }
        }
        private void btn_logout_Click(object sender, EventArgs e)
        {
            //构造信息头
            PacketHeaderStruct phs = new PacketHeaderStruct();
            phs.type = StructConfig.GetHeaderIndexByType(HeaderType.UserLogout);
            phs.length = 0;
            this._clntSocket.Send(phs);
        }
        private void rbtn_one_Click(object sender, EventArgs e)
        {
            this.rbtn_all.Checked = false;
            this.rbtn_one.Checked = true;
            this.cbb_user_list.Enabled = true;
        }

        private void rbtn_all_Click(object sender, EventArgs e)
        {
            this.rbtn_all.Checked = true;
            this.rbtn_one.Checked = false;
            this.cbb_user_list.Enabled = false;
        }

        private void btn_send_Click(object sender, EventArgs e)
        {
            if (this._clntSocket != null && this._clntSocket.IsConnected)
            {
                //构造信息体
                MsgData msgData = new MsgData();
                msgData.Msg = this.txt_send.Text.Trim();
                if (this.rbtn_all.Checked)
                {
                    msgData.IsBroadcast = true;
                }
                else
                {
                    msgData.IsBroadcast = false;
                    msgData.Target = this.cbb_user_list.SelectedItem.ToString();
                }
                byte[] msgBin = SerializeTools.ObjSerialize(msgData);
                //构造信息头
                PacketHeaderStruct phs = new PacketHeaderStruct();
                phs.type = StructConfig.GetHeaderIndexByType(HeaderType.SendMessage);
                phs.length = msgBin.Length;
                //发送
                this._clntSocket.Send(phs);
                this._clntSocket.Send(msgBin);
                //加入一条信息到文本框
                if (this.rbtn_one.Checked)
                {
                    this.txt_msg_list.AppendText("[我]对[" this.cbb_user_list.Text "]说："   msgData.Msg   "\r\n");
                }
                this.txt_send.Text = "";
            }
        }

        private void btn_test_Click(object sender, EventArgs e)
        {
            MessageBox.Show(this.cbb_user_list.Text);
        }

        private void ClientWinMain_FormClosed(object sender, FormClosedEventArgs e)
        {
            if (this._clntSocket.IsConnected)
            {
                this._clntSocket.Stop();

            }
        }

        private void txt_send_KeyPress(object sender, KeyPressEventArgs e)
        {
            TextBox inputBox = sender as TextBox;
            if(e.KeyChar=='\r')
            {
                e.Handled = true;//表示已经处理过按键，目的：取消“滴”的声音
                this.btn_send_Click(sender, e);
            }
        }

    }
}