C# – Simple Multi-threaded/Multi-connection TCP Server

Trong bài này bạn sẽ thấy hai phiên bản TCP Server sử dụng Thread cho phép nhiều kết nối cùng một lúc. Sau đó bạn có thể tạo một client như trong bài ‘C# – Lập trình Socket giao tiếp TCP client/server’ để kiểm tra. Tuy nhiên trong bài này tôi sẽ sử dụng telnet để tạo nhiều kết nối đến server.

Hướng tiếp cận 1: Chấp nhận kết nối lần lượt

Phiên bản này cho phép các kết nối diễn ra lần lượt bằng cách đợi kết nối từ client và sẽ tạo ra thread sau khi kết nối được hình thành. Server sẽ nhận dữ liệu từ client là một chuỗi id, dựa vào đó server sẽ tìm và trả về tên tương ứng với id đó lấy trong dữ liệu là một Dictionary. Để hiểu thêm bạn có thể coi lại các bài viết trước mà tôi đã giới thiệu (xem phần Related articles ở cuối).

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

class StudentTCPServer{

	const int MAX_CONNECTION = 10;
	const int PORT_NUMBER=9999;
	static int _connectionsCount=0;
	static TcpListener listener;

	static Dictionary<string, string> _data =
		new Dictionary<string, string>
	{
		{"1","Thomas"},
		{"2","John"},
		{"3","Joseph"},
		{"4","Paul"},
		{"5","Matthew"},
	};

	public static void Main()
	{
		IPAddress address = IPAddress.Parse("127.0.0.1");

		listener = new TcpListener(address,PORT_NUMBER);
		Console.WriteLine("Waiting for connection...");
		listener.Start();

		while(_connectionsCount<MAX_CONNECTION || MAX_CONNECTION==0)
		{
			Socket soc = listener.AcceptSocket();
			_connectionsCount++;

			Thread t = new Thread((obj)=>
			                      {
			                      	DoWork((Socket)obj);
			                      });
			t.Start(soc);
		}
	}

	static void DoWork(Socket soc)
	{
		Console.WriteLine("Connection received from: {0}",
		                  soc.RemoteEndPoint);
		try{
			var stream = new NetworkStream(soc);
			var reader = new StreamReader(stream);
			var writer = new StreamWriter(stream);
			writer.AutoFlush = true;

			writer.WriteLine("Welcome to Student TCP Server");
			writer.WriteLine("Please enter the student id");

			while(true)
			{
				string id = reader.ReadLine();

				if(String.IsNullOrEmpty(id))
					break; // disconnect

				if(_data.ContainsKey(id))
					writer.WriteLine("Student's name: '{0}'",_data[id]);
				else
					writer.WriteLine("Can't find name for student id '{0}'",id);
			}
			stream.Close();
		}
		catch(Exception ex)
		{
			Console.WriteLine("Error: "+ex);
		}

		Console.WriteLine("Client disconnected: {0}",
		                  soc.RemoteEndPoint);
		soc.Close();
	}
}

Hướng tiếp cận 2: Chấp nhận kết nối đồng thời

Điểm khác biệt của phiên bản này so với phiên bản 1 là ta sẽ tạo sẵn một số lượng thread (MAX_CONNECTION) và mỗi thread sẽ có nhiệm vụ chờ đợi, tạo kết nối cũng như tương tác với client. Bạn có thể thấy điểm khác biệt chính là do vị trí đặt phương thức TCPListener.AcceptSocket() bên trong hay ngoài thread.

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

class StudentTCPServer{

	const int MAX_CONNECTION = 10;
	const int PORT_NUMBER=9999;

	static TcpListener listener;

	static Dictionary<string, string> _data =
		new Dictionary<string, string>
	{
		{"1","Thomas"},
		{"2","John"},
		{"3","Joseph"},
		{"4","Paul"},
		{"5","Matthew"},
	};

	public static void Main()
	{
		IPAddress address = IPAddress.Parse("127.0.0.1");

		listener = new TcpListener(address,PORT_NUMBER);
		Console.WriteLine("Waiting for connection...");
		listener.Start();

		for(int i = 0;i < MAX_CONNECTION;i++){
			new Thread(DoWork).Start();
		}
	}

	static void DoWork()
	{
		while(true)
		{
			Socket soc = listener.AcceptSocket();

			Console.WriteLine("Connection received from: {0}",
			                  soc.RemoteEndPoint);
			try{
				var stream = new NetworkStream(soc);
				var reader = new StreamReader(stream);
				var writer = new StreamWriter(stream);
				writer.AutoFlush = true;

				writer.WriteLine("Welcome to Student TCP Server");
				writer.WriteLine("Please enter the student id");

				while(true)
				{
					string id = reader.ReadLine();

					if(String.IsNullOrEmpty(id))
						break; // disconnect

					if(_data.ContainsKey(id))
						writer.WriteLine("Student's name: '{0}'",_data[id]);
					else
						writer.WriteLine("Can't find name for student id '{0}'",id);
				}
				stream.Close();
			}
			catch(Exception ex)
			{
				Console.WriteLine("Error: "+ex);
			}

			Console.WriteLine("Client disconnected: {0}",
			                  soc.RemoteEndPoint);
			soc.Close();
		}
	}
}

Kiểm tra bằng telnet

Bạn mở Command Prompt lên (Run>cmd) và gõ vào lệnh

telnet localhost 9999

Nếu kết nối thành công bạn sẽ nhận được thông điệp từ server:

Welcome to Student TCP Server
Please enter the student id

Trong Windows Seven, nếu Telnet Client chưa được kích hoạt, bạn vào Control Panel>Programs and Feautures>Turn Windows features on or off. Trong bảng Windows Features, đánh chọn vào mục Telnet Client (như hình sau):

Bạn có thể thay đối giá trị của hằng MAX_CONNECTION để thay đổi số lượng kết nối tới server.

48 thoughts on “C# – Simple Multi-threaded/Multi-connection TCP Server

  1. Mình đang xây dựng chương trình nhận video từ Client về. Server chứa nhiều picturebox mỗi picture box sẽ dùng để hiển thị video của Client gửi về, trong trường hợp 1 client thì không sao. Trong trường hợp nhiều client có cách nào để phân biệt kết nối của mỗi client cũng như dữ liệu của từng client, hoặc có cách nào để mỗi client sau khi gửi dữ liệu sẽ lưu dữ liệu trên 1 picture box riêng ko bạn.

    Trả lời
  2. Chào bạn , mình có 1 vấn đề với server này 😀
    Đó là khi server của mình ngừng lắng nghe , mình đã đóng cổng Socket , và đóng Thread bằng lệnh thread.Abort();
    Nhưng khi đóng form Server , tại Task Manager thì Server của mình vẫn chạy , almf cho không thể bật lại mà không tắt nó đi.
    Bnaj cso thể hướn dẫn để làm sao tắt triệt để cái server đi ko , thanks 😀

    Trả lời
      • mình sử dụng cách thứ 2 của bạn , đó là tạo ra 1 số thread nhất định rồi chờ đợi kết nối từ phía client , mình đoán là do khi đóng chương trình, 1 số thread vẫn chưa đóng và mình đã thử đóng các thread trong hàm Dowork() tuy nhiên vẫn không được . Mình cũng đã thử Application.Exit() và Environment.Exit() vẫn vậy .
        Khi mình thử dùng listener.Stop(); thì chương trình báo lỗi , ko biết sao :-s

  3. chào các anh, e đang làm một ứng dụng có sử dụng socket, trong khi server đang chờ kết nối từ clients thì cửa sổ server cứ đơ ra, nó để là “not responding” và không update được giao diện đồ họa ạ.. có cách nào để nó không còn “not responding” và update được giao diện ngay lập tức khi có thay đổi được không ạ.. em cảm ơn

    Trả lời
  4. Lập trình mạng với giao thức TCP thì 1 server có kết nối được với nhiều client không các bạn. Nếu được thì phải lập trình theo kểu nào. Nếu cóc code thì càng tốt 😀

    Trả lời
  5. bạn ơi cho mình hỏi là có thể show một form mới trong thread background không? mình làm thì nó cứ báo lỗi không thể khởi tạo còn show messagebox thì vẫn bình thường (mình làm bằng Wpf c#)!có cách nào để khắc phục không ạ.

    Trả lời
    • Việc chat qua internet đòi hỏi bạn cần có server với IP tĩnh để nhận và gửi các thông điệp giữa các client. Cách lập trình thì cũng tương tự như chat trong mạng LAN nên cps lẽ là người ta sẽ không tạo các ví dụ này.

      Trả lời
  6. bài viết rất hữu ích!
    mình có vấn đề này muốn hỏi. bài trên chỉ là truyền dữ liệu dạng byte thui phải không ạ? mình muốn truyền dữ liệu dạng hình ảnh từ form Server sang form Client thì làm thế nào? (cả 2 form đều có picturebox)

    Trả lời
  7. Chào bạn! mình đang lập trình trên c# để nhận dữ liệu từ client ( client của mình là một phần cứng rời có chức năng như 1 máy con có thể truy cập vào nó như 1 web), trên giao diện chính là server của mình mình muốn đọc dữ liệu từ nó để hiển thị lên datagridview thì làm thế nào.Sử dụng ví dụ của bạn dc k?

    Trả lời
  8. chào Yin Yang, bạn cho mình hỏi là : mình có 1 from server muốn nhận dữ liệu từ nhiều from client khác,bên server mình có 1 button để start server, nhưng khi minh ấn start server thì from server bị đơ luôn( vẫn báo k có lỗi nào cả ) .Minh cũng chỉ mới bắt đầu tìm hiểu, mong sớm nhận được hồi đáp của bạn

    Trả lời
    • Khi một client kết nối đến thì bạn chỉ cần lưu nó lại vào một collection. Khi server gửi dữ liệu thì sẽ lặp qua collection đó và gửi cho từng client. Chỉ khác nhau ở cấu trúc dữ liệu dùng để lưu trữ client thôi.

      Trả lời
  9. làm phiền Yin Yang, bạn có thể cho thể chạy timer trong thread trong được không.
    Không hiểu sao mình dùng timer để chạy để cập nhật thời gian trên client, khi client kết nói được với server rồi, thì mình cho timer chạy nhưng không có tác dụng gì cả?
    Cảm ơn nhiều.

    Trả lời
  10. Chào bạn, mình thiết lập 1 hệ thống 4 client vs 1 sever kết nối với nhau tuần tự như trường hợp đầu tiên của bạn. Nhưng trong client mặc dù đóng form client thì tiến trình vẫn còn chạy trong task manager mặc dù mình đã đóng kết nối trên client khi close form.

    Trả lời
  11. Chào bạn Yin yang, mình đang làm một phần mềm liên kết với máy xét nghiệm của bệnh viện và gặp vấn đề sau. máy xét nghiệm kết nối với máy chủ thông qua host. Bây giờ mình muốn lấy được tập tin mà máy xét nghiệm trả về thì phải làm thế nào hả bạn!

    Trả lời
  12. chào Yin Yang !
    mình đang làm bài tập chat giữa client với client thông qua server. mà đề thì phải sử dụng ngôn ngữ C++. mong bạn giúp đỡ . mình chỉ ko biết cách để server phân biết các client với nhau như thế nào(tạo mãng mình ko hiễu @@), tạo luồng cho từng clien kết nối đến thì mình ko làm dc . kiến thức mình còn non. mong bạn giúp đỡ . mình đã có thể viết code cho server chat với client nhưng client với client thông qua sever thì mình làm ko dc!!

    Trả lời
  13. Chào bạn . Mình đang muốn làm một demo để hiểu thêm về socket, demo của mình là server sẽ gửi liên tục các gói N bytes về client, client sẽ nhận các gói đó, với mỗi gói client sẽ có xữ lý dựa trên dữ liệu là gói nhận được . Mình không biết làm sao để chạy mượt quá trình này, mong bạn gợi ý . cảm ơn bạn 😀

    Trả lời

Gửi phản hồi

Mời bạn điền thông tin vào ô dưới đây hoặc kích vào một biểu tượng để đăng nhập:

WordPress.com Logo

Bạn đang bình luận bằng tài khoản WordPress.com Log Out / Thay đổi )

Twitter picture

Bạn đang bình luận bằng tài khoản Twitter Log Out / Thay đổi )

Facebook photo

Bạn đang bình luận bằng tài khoản Facebook Log Out / Thay đổi )

Google+ photo

Bạn đang bình luận bằng tài khoản Google+ Log Out / Thay đổi )

Connecting to %s