asp.net基于C# Socket聊天程序（一个服务端，多个客户端）

时间：2022-06-25 04:00:57 编辑：袖梨来源：一聚教程网

部分代码：

命名空间：

代码如下	复制代码
using System.Net; using System.Net.Sockets; using System.Threading; using System.IO;

mainform.cs

代码如下

复制代码

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.IO;

namespace SyncChatServer
{
    public partial class MainForm : Form
    {
        ///

/// 保存连接的所有用户
///

private List userList = new List();

///

/// 服务器IP地址
///

;
private string ServerIP;

///

/// 监听端口
///

private int port;
private TcpListener myListener;

///

/// 是否正常退出所有接收线程
///

bool isNormalExit = false;

        public MainForm()
        {
            InitializeComponent();
            lst_State.HorizontalScrollbar = true;
            btn_Stop.Enabled = false;
            SetServerIPAndPort();
        }

///

        /// 根据当前程序目录的文本文件‘ServerIPAndPort.txt’内容来设定IP和端口
        /// 格式：127.0.0.1:8885
        ///

        private void SetServerIPAndPort()
        {
            FileStream fs = new FileStream("ServerIPAndPort.txt", FileMode.Open);
            StreamReader sr = new StreamReader(fs);
            string IPAndPort = sr.ReadLine();
            ServerIP = IPAndPort.Split(':')[0]; //设定IP
            port = int.Parse(IPAndPort.Split(':')[1]); //设定端口
            sr.Close();
            fs.Close();
        }

///

/// 开始监听
///

        ///
        ///
        private void btn_Start_Click(object sender, EventArgs e)
        {
            myListener = new TcpListener(IPAddress.Parse(ServerIP), port);
            myListener.Start();
            AddItemToListBox(string.Format("开始在{0}:{1}监听客户连接", ServerIP, port));
            //创建一个线程监客户端连接请求
            Thread myThread = new Thread(ListenClientConnect);
            myThread.Start();
            btn_Start.Enabled = false;
            btn_Stop.Enabled = true;
        }

///

/// 接收客户端连接
///

        private void ListenClientConnect()
        {
            TcpClient newClient = null;
            while (true)
            {
                try
                {
                    newClient = myListener.AcceptTcpClient();
                }
                catch
                {
                    //当单击‘停止监听’或者退出此窗体时 AcceptTcpClient() 会产生异常
                    //因此可以利用此异常退出循环
                    break;
                }
                //每接收一个客户端连接，就创建一个对应的线程循环接收该客户端发来的信息；
                User user = new User(newClient);
                Thread threadReceive = new Thread(ReceiveData);
                threadReceive.Start(user);
                userList.Add(user);
                AddItemToListBox(string.Format("[{0}]进入", newClient.Client.RemoteEndPoint));
                AddItemToListBox(string.Format("当前连接用户数：{0}", userList.Count));
            }

}

///

/// 处理接收的客户端信息
///

        /// 客户端信息
        private void ReceiveData(object userState)
        {
            User user = (User)userState;
            TcpClient client = user.client;
            while (isNormalExit == false)
            {
                string receiveString = null;
                try
                {
                    //从网络流中读出字符串，此方法会自动判断字符串长度前缀
                    receiveString = user.br.ReadString();
                }
                catch (Exception)
                {
                    if (isNormalExit == false)
                    {
                        AddItemToListBox(string.Format("与[{0}]失去联系，已终止接收该用户信息", client.Client.RemoteEndPoint));
                        RemoveUser(user);
                    }
                    break;
                }
                AddItemToListBox(string.Format("来自[{0}]：{1}",user.client.Client.RemoteEndPoint,receiveString));
                string[] splitString = receiveString.Split(',');
                switch(splitString[0])
                {
                    case "Login":
                        user.userName = splitString[1];
                        SendToAllClient(user,receiveString);
                        break;
                    case "Logout":
                        SendToAllClient(user,receiveString);
                        RemoveUser(user);
                        return;
                    case "Talk":
                        string talkString = receiveString.Substring(splitString[0].Length + splitString[1].Length + 2);
                        AddItemToListBox(string.Format("{0}对{1}说：{2}",user.userName,splitString[1],talkString));
                        SendToClient(user,"talk," + user.userName + "," + talkString);
                        foreach(User target in userList)
                        {
                            if(target.userName == splitString[1] && user.userName != splitString[1])
                            {
                                SendToClient(target,"talk," + user.userName + "," + talkString);
                                break;
                            }
                        }
                        break;
                    default:
                        AddItemToListBox("什么意思啊：" + receiveString);
                        break;
                }
            }
        }

///

/// 发送消息给所有客户
///

        /// 指定发给哪个用户
        /// 信息内容
        private void SendToAllClient(User user, string message)
        {
            string command = message.Split(',')[0].ToLower();
            if (command == "login")
            {
                //获取所有客户端在线信息到当前登录用户
                for (int i = 0; i < userList.Count; i++)
                {
                    SendToClient(user, "login," + userList[i].userName);
                }
                //把自己上线，发送给所有客户端
                for (int i = 0; i < userList.Count; i++)
                {
                    if (user.userName != userList[i].userName)
                    {
                        SendToClient(userList[i], "login," + user.userName);
                    }
                }
            }
            else if(command == "logout")
            {
                for (int i = 0; i < userList.Count; i++)
                {
                    if (userList[i].userName != user.userName)
                    {
                        SendToClient(userList[i], message);
                    }
                }
            }
        }

///

/// 发送 message 给 user
///

        /// 指定发给哪个用户
        /// 信息内容
        private void SendToClient(User user, string message)
        {
            try
            {
                //将字符串写入网络流，此方法会自动附加字符串长度前缀
                user.bw.Write(message);
                user.bw.Flush();
                AddItemToListBox(string.Format("向[{0}]发送：{1}", user.userName, message));
            }
            catch
            {
                AddItemToListBox(string.Format("向[{0}]发送信息失败",user.userName));
            }
        }

///

/// 移除用户
///

        /// 指定要移除的用户
        private void RemoveUser(User user)
        {
            userList.Remove(user);
            user.Close();
            AddItemToListBox(string.Format("当前连接用户数：{0}",userList.Count));
        }

private delegate void AddItemToListBoxDelegate(string str);
///

/// 在ListBox中追加状态信息
///

        /// 要追加的信息
        private void AddItemToListBox(string str)
        {
            if (lst_State.InvokeRequired)
            {
                AddItemToListBoxDelegate d = AddItemToListBox;
                lst_State.Invoke(d, str);
            }
            else
            {
                lst_State.Items.Add(str);
                lst_State.SelectedIndex = lst_State.Items.Count - 1;
                lst_State.ClearSelected();
            }
        }

///

/// 停止监听
///

        ///
        ///
        private void btn_Stop_Click(object sender, EventArgs e)
        {
            AddItemToListBox("开始停止服务，并依次使用户退出！");
            isNormalExit = true;
            for (int i = userList.Count - 1; i >= 0; i--)
            {
                RemoveUser(userList[i]);
            }
            //通过停止监听让 myListener.AcceptTcpClient() 产生异常退出监听线程
            myListener.Stop();
            btn_Start.Enabled = true;
            btn_Stop.Enabled = false;
        }

///

/// 关闭窗口时触发的事件
///

        ///
        ///
        private void MainForm_FormClosing(object sender, FormClosingEventArgs e)
        {
            if (myListener != null)
                btn_Stop.PerformClick();    //引发 btn_Stop 的Click事件
        }
    }
}

代码片段：

代码如下

复制代码

///

/// 根据当前程序目录的文本文件‘ServerIPAndPort.txt’内容来设定IP和端口
/// 格式：127.0.0.1:8885
///

private void SetServerIPAndPort()
{
    FileStream fs = new FileStream("ServerIPAndPort.txt", FileMode.Open);
    StreamReader sr = new StreamReader(fs);
    string IPAndPort = sr.ReadLine();
    ServerIP = IPAndPort.Split(':')[0]; //设定IP
    port = int.Parse(IPAndPort.Split(':')[1]); //设定端口
    sr.Close();
    fs.Close();
}

///

/// 开始监听
///

///
///
private void btn_Start_Click(object sender, EventArgs e)
{
    myListener = new TcpListener(IPAddress.Parse(ServerIP), port);
    myListener.Start();
    AddItemToListBox(string.Format("开始在{0}:{1}监听客户连接", ServerIP, port));
    //创建一个线程监客户端连接请求
    Thread myThread = new Thread(ListenClientConnect);
    myThread.Start();
    btn_Start.Enabled = false;
    btn_Stop.Enabled = true;
}

///

/// 接收客户端连接
///

private void ListenClientConnect()
{
    TcpClient newClient = null;
    while (true)
    {
        try
        {
            newClient = myListener.AcceptTcpClient();
        }
        catch
        {
            //当单击‘停止监听’或者退出此窗体时 AcceptTcpClient() 会产生异常
            //因此可以利用此异常退出循环
            break;
        }
        //每接收一个客户端连接，就创建一个对应的线程循环接收该客户端发来的信息；
        User user = new User(newClient);
        Thread threadReceive = new Thread(ReceiveData);
        threadReceive.Start(user);
        userList.Add(user);
        AddItemToListBox(string.Format("[{0}]进入", newClient.Client.RemoteEndPoint));
        AddItemToListBox(string.Format("当前连接用户数：{0}", userList.Count));
    }

}

///

/// 处理接收的客户端信息
///

/// 客户端信息
private void ReceiveData(object userState)
{
    User user = (User)userState;
    TcpClient client = user.client;
    while (isNormalExit == false)
    {
        string receiveString = null;
        try
        {
            //从网络流中读出字符串，此方法会自动判断字符串长度前缀
            receiveString = user.br.ReadString();
        }
        catch (Exception)
        {
            if (isNormalExit == false)
            {
                AddItemToListBox(string.Format("与[{0}]失去联系，已终止接收该用户信息", client.Client.RemoteEndPoint));
                RemoveUser(user);
            }
            break;
        }
        AddItemToListBox(string.Format("来自[{0}]：{1}",user.client.Client.RemoteEndPoint,receiveString));
        string[] splitString = receiveString.Split(',');
        switch(splitString[0])
        {
            case "Login":
                user.userName = splitString[1];
                SendToAllClient(user,receiveString);
                break;
            case "Logout":
                SendToAllClient(user,receiveString);
                RemoveUser(user);
                return;
            case "Talk":
                string talkString = receiveString.Substring(splitString[0].Length + splitString[1].Length + 2);
                AddItemToListBox(string.Format("{0}对{1}说：{2}",user.userName,splitString[1],talkString));
                SendToClient(user,"talk," + user.userName + "," + talkString);
                foreach(User target in userList)
                {
                    if(target.userName == splitString[1] && user.userName != splitString[1])
                    {
                        SendToClient(target,"talk," + user.userName + "," + talkString);
                        break;
                    }
                }
                break;
            default:
                AddItemToListBox("什么意思啊：" + receiveString);
                break;
        }
    }
}

user.cs

代码如下

复制代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.IO;

namespace SyncChatServer
{
    class User
    {
        public TcpClient client { get; private set; }
        public BinaryReader br { get; private set; }
        public BinaryWriter bw { get; private set; }
        public string userName { get; set; }

        public User(TcpClient client)
        {
            this.client = client;
            NetworkStream networkStream = client.GetStream();
            br = new BinaryReader(networkStream);
            bw = new BinaryWriter(networkStream);
        }

        public void Close()
        {
            br.Close();
            bw.Close();
            client.Close();
        }

}
}

program.cs

代码如下

复制代码

using System;
using System.Collections.Generic;
using System.Linq;
using System.Windows.Forms;

namespace SyncChatServer
{
    static class Program
    {
        ///

/// 应用程序的主入口点。
///

        [STAThread]
        static void Main()
        {
            Application.EnableVisualStyles();
            Application.SetCompatibleTextRenderingDefault(false);
            Application.Run(new MainForm());
        }
    }
}

main.cs

代码如下

复制代码

namespace SyncChatServer
{
    partial class MainForm
    {
        ///

/// 必需的设计器变量。
///

private System.ComponentModel.IContainer components = null;

///

/// 清理所有正在使用的资源。
///

        /// 如果应释放托管资源，为 true；否则为 false。
        protected override void Dispose(bool disposing)
        {
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }

#region Windows 窗体设计器生成的代码

///

        /// 设计器支持所需的方法 - 不要
        /// 使用代码编辑器修改此方法的内容。
        ///

        private void InitializeComponent()
        {
            this.groupBox1 = new System.Windows.Forms.GroupBox();
            this.lst_State = new System.Windows.Forms.ListBox();
            this.btn_Start = new System.Windows.Forms.Button();
            this.btn_Stop = new System.Windows.Forms.Button();
            this.groupBox1.SuspendLayout();
            this.SuspendLayout();
            //
            // groupBox1
            //
            this.groupBox1.Controls.Add(this.lst_State);
            this.groupBox1.Location = new System.Drawing.Point(12, 12);
            this.groupBox1.Name = "groupBox1";
            this.groupBox1.Size = new System.Drawing.Size(523, 327);
            this.groupBox1.TabIndex = 0;
            this.groupBox1.TabStop = false;
            this.groupBox1.Text = "状态信息";
            //
            // lst_State
            //
            this.lst_State.Dock = System.Windows.Forms.DockStyle.Fill;
            this.lst_State.FormattingEnabled = true;
            this.lst_State.ItemHeight = 12;
            this.lst_State.Location = new System.Drawing.Point(3, 17);
            this.lst_State.Name = "lst_State";
            this.lst_State.Size = new System.Drawing.Size(517, 304);
            this.lst_State.TabIndex = 0;
            //
            // btn_Start
            //
            this.btn_Start.Location = new System.Drawing.Point(126, 346);
            this.btn_Start.Name = "btn_Start";
            this.btn_Start.Size = new System.Drawing.Size(75, 23);
            this.btn_Start.TabIndex = 1;
            this.btn_Start.Text = "开始监听";
            this.btn_Start.UseVisualStyleBackColor = true;
            this.btn_Start.Click += new System.EventHandler(this.btn_Start_Click);
            //
            // btn_Stop
            //
            this.btn_Stop.Location = new System.Drawing.Point(322, 346);
            this.btn_Stop.Name = "btn_Stop";
            this.btn_Stop.Size = new System.Drawing.Size(75, 23);
            this.btn_Stop.TabIndex = 2;
            this.btn_Stop.Text = "停止监听";
            this.btn_Stop.UseVisualStyleBackColor = true;
            this.btn_Stop.Click += new System.EventHandler(this.btn_Stop_Click);
            //
            // MainForm
            //
            this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
            this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
            this.ClientSize = new System.Drawing.Size(547, 375);
            this.Controls.Add(this.btn_Stop);
            this.Controls.Add(this.btn_Start);
            this.Controls.Add(this.groupBox1);
            this.Name = "MainForm";
            this.Text = "SyncChatServer";
            this.FormClosing += new System.Windows.Forms.FormClosingEventHandler(this.MainForm_FormClosing);
            this.groupBox1.ResumeLayout(false);
            this.ResumeLayout(false);

}

#endregion

        private System.Windows.Forms.GroupBox groupBox1;
        private System.Windows.Forms.ListBox lst_State;
        private System.Windows.Forms.Button btn_Start;
        private System.Windows.Forms.Button btn_Stop;
    }
}

以上是不完整的代码片段，由于代码太多这里贴出来肯定眼花缭乱的。。

有需要的朋友还是下载源码看把

点击下载源文件

推荐专题

最新下载

热门教程

asp.net基于C# Socket聊天程序（一个服务端，多个客户端）

相关文章

热门栏目

php教程

asp.net教程

手机开发

css教程

网页制作

办公数码

jsp教程