C#中Socket对象的Tag属性

在C#中，Socket对象的Tag属性是一个对象，可以用来存储与Socket对象相关的任何信息。Tag属性通常用于存储自定义数据，例如表示Socket连接的用户信息、连接状态等。使用Tag属性可以方便地将自定义数据与Socket对象关联起来，并且在需要时可以轻松地访问这些数据。可以通过以下方式设置Socket对象的Tag属性：socketObject.Tag = customData; 其中，socketObject是一个Socket对象，customData是一个自定义数据对象。可以通过以下方式访问Socket对象的Tag属性：customData = socketObject.Tag; 其中，socketObject是一个Socket对象，customData是一个自定义数据对象。

相关问题

C# 用socket实现由用户向其他指定用户发送信息

要使用C#的Socket实现由用户向其他指定用户发送信息，需要涉及到以下几个步骤：

1. 创建一个服务器端Socket，用于接收客户端连接请求，并将连接的客户端加入到一个列表中；
2. 创建一个客户端Socket，用于与服务器端Socket建立连接；
3. 客户端向服务器端发送连接请求，并通过用户名等信息标识自己；
4. 服务器端接收到连接请求后，根据用户名等信息将客户端Socket加入到一个列表中；
5. 客户端可以向服务器端发送消息，服务器端接收到消息后，根据消息中的目标用户，将消息转发给目标用户对应的Socket；
6. 当客户端断开连接时，需要将其从列表中移除。

以下是一个简单的示例代码：

服务器端代码：

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

namespace SocketServer
{
    class Program
    {
        static void Main(string[] args)
        {
            // 创建一个Socket对象
            Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // 绑定IP地址和端口号
            IPAddress ipAddress = IPAddress.Any;
            IPEndPoint localEP = new IPEndPoint(ipAddress, 12345);
            serverSocket.Bind(localEP);

            // 开始监听连接请求
            serverSocket.Listen(10);

            // 创建一个列表，用于保存已连接的客户端Socket
            List<Socket> clientSockets = new List<Socket>();

            Console.WriteLine("服务器已启动，等待客户端连接...");

            while (true)
            {
                // 接收客户端连接请求，并将连接的客户端Socket加入到列表中
                Socket clientSocket = serverSocket.Accept();
                clientSockets.Add(clientSocket);

                Console.WriteLine("客户端已连接：" + clientSocket.RemoteEndPoint.ToString());

                // 开启一个线程处理客户端消息
                System.Threading.Thread thread = new System.Threading.Thread(() =>
                {
                    try
                    {
                        while (true)
                        {
                            // 接收客户端发送的消息
                            byte[] buffer = new byte[1024];
                            int length = clientSocket.Receive(buffer);
                            string message = Encoding.UTF8.GetString(buffer, 0, length);

                            // 判断消息类型，如果是连接请求，则将客户端信息保存到列表中
                            if (message.StartsWith("login:"))
                            {
                                string username = message.Substring(6);
                                Console.WriteLine("客户端登录：" + username);

                                // 将客户端信息保存到Socket对象的Tag属性中
                                clientSocket.Tag = username;
                            }
                            // 如果是普通消息，则将消息转发给目标用户
                            else if (message.StartsWith("msg:"))
                            {
                                string[] parts = message.Substring(4).Split(new char[] { ':' }, 2);
                                string targetUser = parts[0];
                                string content = parts[1];

                                Console.WriteLine("客户端发送消息：" + content);

                                // 查找目标用户对应的Socket对象
                                Socket targetSocket = clientSockets.Find(s => s.Tag.ToString() == targetUser);

                                // 如果找到目标Socket对象，则将消息转发给目标用户
                                if (targetSocket != null)
                                {
                                    targetSocket.Send(Encoding.UTF8.GetBytes(content));
                                }
                            }
                        }
                    }
                    catch
                    {
                        // 发生异常时，将客户端Socket从列表中移除
                        clientSockets.Remove(clientSocket);
                        Console.WriteLine("客户端已断开：" + clientSocket.RemoteEndPoint.ToString());
                    }
                });
                thread.Start();
            }
        }
    }
}

客户端代码：

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace SocketClient
{
    class Program
    {
        static void Main(string[] args)
        {
            // 创建一个Socket对象
            Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // 连接到服务器端
            IPAddress ipAddress = IPAddress.Parse("192.168.1.100");
            IPEndPoint remoteEP = new IPEndPoint(ipAddress, 12345);
            clientSocket.Connect(remoteEP);

            // 发送登录消息
            Console.Write("请输入用户名：");
            string username = Console.ReadLine();
            string message = "login:" + username;
            clientSocket.Send(Encoding.UTF8.GetBytes(message));

            // 开启一个线程接收服务器端消息
            System.Threading.Thread thread = new System.Threading.Thread(() =>
            {
                try
                {
                    while (true)
                    {
                        // 接收服务器端发送的消息
                        byte[] buffer = new byte[1024];
                        int length = clientSocket.Receive(buffer);
                        string content = Encoding.UTF8.GetString(buffer, 0, length);

                        Console.WriteLine(content);
                    }
                }
                catch
                {
                    // 发生异常时，关闭客户端Socket
                    clientSocket.Close();
                }
            });
            thread.Start();

            // 循环发送消息
            while (true)
            {
                Console.Write("请输入目标用户和消息（格式为“用户名:消息”）：");
                string input = Console.ReadLine();

                // 发送消息
                message = "msg:" + input;
                clientSocket.Send(Encoding.UTF8.GetBytes(message));
            }
        }
    }
}

在上面的代码中，我们创建了一个服务器端Socket，并在循环中接收客户端连接请求，并将连接的客户端Socket加入到一个列表中。在接收到客户端发送的消息后，根据消息类型将客户端信息保存到Socket对象的Tag属性中，或者将消息转发给目标用户对应的Socket。当客户端断开连接时，需要将其从列表中移除。

在客户端代码中，我们首先连接到服务器端，并发送登录消息，指定自己的用户名。然后开启一个线程接收服务器端发送的消息，循环读取用户输入的目标用户和消息，并向服务器端发送消息。