Всем здравствуйте.
В С# я новичек, поэтому просьба не судить строго.
Задача - написать простой echo сервер. Подключение к серверу любым клиентом(telnet,putty).
Задача выполнена, привожу свою реализацию ниже. Огромная просьба прокомментировать код.
Класс самого сервера:
| C# |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
| using System;
using System.Net;
using System.Net.Sockets;
class Server
{
TcpListener Listener;
public Server(int port)
{
Console.WriteLine("Сервер запущен, слушает порт " + port);
Listener = new TcpListener(IPAddress.Any, port);
Listener.Start();
while (true)
{
// Принимаем новых клиентов
Client client = new Client(Listener.AcceptTcpClient());
Console.WriteLine("Новый клиент подключился с IP: " + client.getIP());
client.sendMessage("Вы подключены к серверу.\n\r");
}
}
~Server()
{
if (Listener != null)
{
// Остановим его
Listener.Stop();
}
}
} |
|
Класс-обработчик входящих соединений:
| C# |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
| using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;
class Client
{
private TcpClient socket;
public Client(TcpClient client)
{
this.socket = client;
}
~Client()
{
if (this.socket != null)
{
this.socket.Close();
}
}
public void sendMessage(String msg)
{
byte[] buffer = Encoding.UTF8.GetBytes(msg);
this.socket.GetStream().Write(buffer, 0, buffer.Length);
Thread receiveThread = new Thread(receiveMessage);
receiveThread.Start();
}
public String getIP()
{
return this.socket.Client.RemoteEndPoint.ToString();
}
private void receiveMessage()
{
while (socket.Connected)
{
byte[] buffer = new byte[socket.Available];
this.socket.GetStream().Read(buffer, 0, buffer.Length);
String message = Encoding.UTF8.GetString(buffer);
sendMessage(message);
}
}
} |
|
Main:
| C# |
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
| using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace ConsoleApplication1
{
class Program
{
static void Main(string[] args)
{
new Server(2100);
}
}
} |
|
Мои вопросы/наблюдения:
1)
| C# |
1
2
3
4
5
6
| private void receiveMessage()
{
while (socket.Connected)
{
byte[] buffer = new byte[socket.Available];
this.socket.GetStream().Read(buffer, 0, buffer.Length); |
|
Последняя операция является блокирующей? Т.е. выполнение while(socket.Connected) будет приостановлено до тех пор, пока на сокете не появятся входящие данные?
2)
| C# |
1
| Thread receiveThread = new Thread(receiveMessage); |
|
Запускает отдельный поток на receiveMessage? Не вызовёт ли это большую нагрузку при большом количестве клиентов? Может быть использовать пул потоков? Тыкните пожалуйста где почитать про это
3) Как отлавливать закрытие сокета в TcpClient?
4) Что здесь можно улучшить?
Добавлено через 2 часа 16 минут
Я извиняюсь, может не в том разделе тему создал? Тишина такая.
(
