c#实现多线程局域网聊天系统

C#实现多线程局域网聊天系统攻略

前言

本文介绍如何使用C#语言编写多线程局域网聊天系统。局域网聊天系统主要用于小范围内的通信，可以在公司、学校或家庭之间使用。使用多线程技术可以提升系统的并发性能，增强用户体验。本文将使用Visual Studio开发工具来进行程序设计和实现。

程序设计

整体架构

1. 客户端程序：用于与其他用户进行通信和交流，需要与服务器程序进行通信才能实现聊天。
2. 服务器程序：用于处理客户端程序的请求和数据，主要职责为消息转发和数据处理，保证系统并发性能和数据的完整性。

程序实现

下面将详细介绍如何实现客户端程序和服务器程序。

客户端程序

客户端程序需要完成以下几个功能：

1. 登录服务器：通过输入IP地址或域名登录到局域网聊天室。
2. 发送消息：将消息发送给其他在线用户。
3. 接收消息：接收其他用户发送的消息，实现即时通讯的效果。
4. 退出系统：用户退出系统时需要向服务器发送退出消息，以便服务器更新用户状态。

以下是示例代码：

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;

public class Client {
    private TcpClient client;
    private NetworkStream stream;
    private Thread thread;

    public Client(string serverIP, int serverPort) {
        client = new TcpClient(serverIP, serverPort);

        stream = client.GetStream();

        thread = new Thread(new ThreadStart(DoWork));
        thread.Start();
    }

    private void DoWork() {
        Console.WriteLine("Connected to chat room server!");

        while (true) {
            byte[] buffer = new byte[1024];
            int len = stream.Read(buffer, 0, buffer.Length);
            string message = Encoding.UTF8.GetString(buffer, 0, len);

            Console.WriteLine("Received message: " + message);
        }
    }

    public void SendMessage(string message) {
        byte[] buffer = Encoding.UTF8.GetBytes(message);
        stream.Write(buffer, 0, buffer.Length);
    }

    public void Close() {
        thread.Abort();
        stream.Close();
        client.Close();
    }
}

服务器程序

服务器程序需要完成以下几个功能：

1. 监听端口：监听指定的端口，等待客户端连接。
2. 处理客户端请求：处理客户端发送的请求，包括登录、发送消息和退出系统。
3. 转发消息：将客户端发送的消息转发给其他在线用户。
4. 保持服务：持续为客户端提供服务，保证系统的可用性和并发性能。

以下是示例代码：

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

public class Server {
    private TcpListener listener;
    private Dictionary<string, TcpClient> clients;
    private Thread thread;

    public Server(int port) {
        listener = new TcpListener(IPAddress.Any, port);

        clients = new Dictionary<string, TcpClient>();

        thread = new Thread(new ThreadStart(DoWork));
        thread.Start();
    }

    private void DoWork() {
        listener.Start();

        Console.WriteLine("Chat room server was started!");

        while (true) {
            TcpClient client = listener.AcceptTcpClient();
            Thread thread = new Thread(new ParameterizedThreadStart(HandleClient));
            thread.Start(client);
        }
    }

    private void HandleClient(object obj) {
        TcpClient client = obj as TcpClient;

        string ip = ((IPEndPoint)client.Client.RemoteEndPoint).Address.ToString();
        clients.Add(ip, client);
        Console.WriteLine(ip + " joined the chat room!");

        NetworkStream stream = client.GetStream();

        while (true) {
            byte[] buffer = new byte[1024];
            int len = stream.Read(buffer, 0, buffer.Length);
            string message = Encoding.UTF8.GetString(buffer, 0, len);

            Console.WriteLine(ip + " sent a message: " + message);
            Broadcast(ip, message);
        }
    }

    private void Broadcast(string ip, string message) {
        foreach (var item in clients) {
            if (item.Key != ip) {
                TcpClient client = item.Value;
                NetworkStream stream = client.GetStream();

                byte[] buffer = Encoding.UTF8.GetBytes(message);
                stream.Write(buffer, 0, buffer.Length);
            }
        }
    }

    public void Close() {
        thread.Abort();
        listener.Stop();
    }
}

总结

本文介绍了使用C#语言实现多线程局域网聊天系统的攻略，主要分为客户端程序和服务器程序两个部分。通过本文所列示的代码，可以在Visual Studio中编写代码，快速搭建出一个简单的局域网聊天系统。