Ошибка обычно разрешается только одно использование адреса сокета

I’ve done a lot of googling but not had much luck with my issues. I am new to network programming and trying to learn, I’ve attempted to set up a simple server & client that communicate (following an online tutorial located here -> http://tech.pro/tutorial/704/csharp-tutorial-simple-threaded-tcp-server)

The issue I’m having is that I keep getting the exception «Only one usage of each socket address (protocol/network address/port) is normally permitted» when trying to start the TcpListener on the server.

I’ve tried disabling my firewall, changing the port to be used, moving variables around but to no avail (the client works fine, but it obviously can’t find the server because I cannot launch it).

I’ve seen solutions describing the use of Socket.Poll() but since I’m only using the TcpListener object, I have no idea how to make use of the Poll function.

My code:

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

namespace ServerTutorial {
class Server {
    private readonly Thread m_listenThread;

    public Server() {
        m_listenThread = new Thread(new ThreadStart(ListenForClients));
        m_listenThread.Start();
    }

    public void ListenForClients() {
        var listener = new TcpListener(IPAddress.Any, 3000);
        listener.Start();

        while (true) {
            //Blocks until a client has connected to the server
            TcpClient client = listener.AcceptTcpClient();

            //Send a message to the client
            var encoder = new ASCIIEncoding();
            NetworkStream clientStream = client.GetStream();
            byte[] buffer = encoder.GetBytes("Hello Client!");
            clientStream.Write(buffer, 0, buffer.Length);
            clientStream.Flush();

            //Create a thread to handle communication with the connected client
            var clientThread = new Thread(new ParameterizedThreadStart(HandleClient));
            clientThread.Start(client);
        }
    }

    private void HandleClient(object clientObj) { //Param thread start can only accept object types, hence the cast
        var client = (TcpClient) clientObj;
        NetworkStream clientStream = client.GetStream();

        var message = new byte[4096];

        while (true) {
            int bytesRead = 0;

            try {
                //Block until a client sends a message
                bytesRead = clientStream.Read(message, 0, 4096);
            } catch {
                //A socket error has occurred
                System.Diagnostics.Debug.WriteLine("A socket error has occured");
                break;
            }

            if (bytesRead == 0) {
                //The client has disconnected from the server
                System.Diagnostics.Debug.WriteLine("A client has disconnected from the server");
                client.Close();
                break;
            }

            //Message has been received
            var encoder = new ASCIIEncoding();
            System.Diagnostics.Debug.WriteLine(encoder.GetString(message, 0, bytesRead));
        }
    }
}
}

In my main method:

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace ServerTutorial {
class Program {
    static void Main(string[] args) {
        var server = new Server();
        server.ListenForClients();
    }
}
}

Any help is hugely appreciated!

You are overloading the TCP/IP stack. Windows (and I think all socket stacks actually) have a limitation on the number of sockets that can be opened in rapid sequence due to how sockets get closed under normal operation. Whenever a socket is closed, it enters the TIME_WAIT state for a certain time (240 seconds IIRC). Each time you poll, a socket is consumed out of the default dynamic range (I think its about 5000 dynamic ports just above 1024), and each time that poll ends, that particular socket goes into TIME_WAIT. If you poll frequently enough, you will eventually consume all of the available ports, which will result in TCP error 10048.

Generally, WCF tries to avoid this problem by pooling connections and things like that. This is usually the case with internal services that are not going over the internet. I am not sure if any of the wsHttp bindings support connection pooling, but the netTcp binding should. I would assume named pipes does not run into this problem. I couldn’t say for the MSMQ binding.

There are two solutions you can use to get around this problem. You can either increase the dynamic port range, or reduce the period of TIME_WAIT. The former is probably the safer route, but if you are consuming an extremely high volume of sockets (which doesn’t sound like the case for your scenario), reducing TIME_WAIT is a better option (or both together.)

Changing the Dynamic Port Range

1. Open regedit.
2. Open key HKLMSystemCurrentControlSetServicesTcpipParameters
3. Edit (or create as DWORD) the MaxUserPort value.
4. Set it to a higher number. (i.e. 65534)

Changing the TIME_WAIT delay

1. Open regedit.
2. Open key HKLMSystemCurrentControlSetServicesTcpipParameters
3. Edit (or create as DWORD) the TcpTimedWaitDelay.
4. Set it to a lower number. Value is in seconds. (i.e. 60 for 1 minute delay)

One of the above solutions should fix your problem. If it persists after changing the port range, I would see try increasing the period of your polling so it happens less frequently…that will give you more leeway to work around the time wait delay. I would change the time wait delay as a last resort.

При «ручном» прогоне плагина выходит ошибка —

>>> RESTART: C:UsersandrewDocumentsMinecraft PythonpypluginsJuicyRaspberryPiemcpipycmdsvr.py
registering command: blk
registering command: hi
Traceback (most recent call last):
  File "C:UsersandrewDocumentsMinecraft PythonpypluginsJuicyRaspberryPiemcpipycmdsvr.py", line 84, in <module>
    server = socketserver.TCPServer((HOST, PORT), MyTCPHandler)
  File "C:UsersandrewAppDataLocalProgramsPythonPython36-32libsocketserver.py", line 453, in __init__
    self.server_bind()
  File "C:UsersandrewAppDataLocalProgramsPythonPython36-32libsocketserver.py", line 467, in server_bind
    self.socket.bind(self.server_address)
OSError: [WinError 10048] Обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт)

Spigot выдаёт при этом ошибку —

[08:44:55 WARN]: java.net.ConnectException: Connection refused: connect
[08:44:55 WARN]:        at java.net.DualStackPlainSocketImpl.connect0(Native Method)
[08:44:55 WARN]:        at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)
[08:44:55 WARN]:        at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)
[08:44:55 WARN]:        at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)
[08:44:55 WARN]:        at java.net.AbstractPlainSocketImpl.connect(Unknown Source)
[08:44:55 WARN]:        at java.net.PlainSocketImpl.connect(Unknown Source)
[08:44:55 WARN]:        at java.net.SocksSocketImpl.connect(Unknown Source)
[08:44:55 WARN]:        at java.net.Socket.connect(Unknown Source)
[08:44:55 WARN]:        at java.net.Socket.connect(Unknown Source)
[08:44:55 WARN]:        at java.net.Socket.<init>(Unknown Source)
[08:44:55 WARN]:        at java.net.Socket.<init>(Unknown Source)
[08:44:55 WARN]:        at org.wensheng.plugins.JuicyRaspberryPie.onCommand(JuicyRaspberryPie.java:153)
[08:44:55 WARN]:        at org.bukkit.command.PluginCommand.execute(PluginCommand.java:44)
[08:44:55 WARN]:        at org.bukkit.command.SimpleCommandMap.dispatch(SimpleCommandMap.java:141)
[08:44:55 WARN]:        at org.bukkit.craftbukkit.v1_12_R1.CraftServer.dispatchCommand(CraftServer.java:649)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.PlayerConnection.handleCommand(PlayerConnection.java:1397)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.PlayerConnection.a(PlayerConnection.java:1232)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.PacketPlayInChat.a(PacketPlayInChat.java:45)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.PacketPlayInChat.a(PacketPlayInChat.java:1)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.PlayerConnectionUtils$1.run(SourceFile:13)
[08:44:55 WARN]:        at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
[08:44:55 WARN]:        at java.util.concurrent.FutureTask.run(Unknown Source)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.SystemUtils.a(SourceFile:46)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.MinecraftServer.D(MinecraftServer.java:748)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.DedicatedServer.D(DedicatedServer.java:406)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.MinecraftServer.C(MinecraftServer.java:679)
[08:44:55 WARN]:        at net.minecraft.server.v1_12_R1.MinecraftServer.run(MinecraftServer.java:577)
[08:44:55 WARN]:        at java.lang.Thread.run(Unknown Source)

Файл на который ругается —

# wenshengwang at gmail dot com
# BSD License
"""This is a TCP server. It is started by the JuicyRaspberryPie plugin and
listen on localhost port 32123.
When it start, it scan the "pplugins" directory for any python files and try
to load them as modules, in these modules, it search for any functions whose
docstring starts with "_mcp" and register them as commands.
When the server receive a command, if it matches one in the registry, it will
be executed. If not, it will execute a dummy command.
"""

import os
import sys
import glob
import socketserver
import threading
import types
import importlib

plugin_dir = os.path.realpath(os.path.join(os.path.dirname(__file__), ".."))
sys.path.insert(0, plugin_dir)
from mcpi.minecraft import Minecraft

HOST = 'localhost'
# TODO: read port from config.yml
PORT = 4444

KEEP_RUNNING = True
def keep_running():
    return KEEP_RUNNING

# command registry
mc_functions = {}

pp_files = glob.glob(os.path.join(plugin_dir, "pplugins", "*.py"))
# import all files and put minecraft function into the mc_functions dict
for pp_file in pp_files:
    basename = os.path.basename(pp_file)
    if basename != "__init__.py":
        try:
            module = importlib.import_module("pplugins." + basename[:-3])
            for item in dir(module):
                if isinstance(module.__dict__[item], types.FunctionType):
                    docs = module.__dict__[item].__doc__
                    if docs and docs.startswith("_mcp"):
                        print("registering command:", module.__dict__[item].__name__)
                        mc_functions[item] = module.__dict__[item]
        except (NameError, ImportError) as e:
            print(e)


def chat(msg="Whaaat?!"):
    mc = Minecraft.create()
    mc.postToChat(msg)


class MyTCPHandler(socketserver.BaseRequestHandler):
    def handle(self):
        global KEEP_RUNNING
        self.data = self.request.recv(1024)
        # firt 2 bytes are length info, from Java's writeUTF
        args = self.data[2:].decode('utf-8').split()
        cmd = args[0]
        if cmd == "list":
            s = "Available commands: %s" % ( " ".join(list(mc_functions.keys())))
            self.request.sendall(s.encode('utf-8'))
            threading.Thread(target=chat, args=(s,), kwargs={}).start()
            return
        if cmd == "help":
            s = 'JuicyRaspberryPie: put your Python files in pplugins, then "/p cmd" to call your function, "/p list" to see list of commands'
            self.request.sendall(s.encode('utf-8'))
            threading.Thread(target=chat, args=(s,), kwargs={}).start()
            return
        if cmd == "BYE":
            print("got shutdown request, signing off")
            KEEP_RUNNING = False
            return
        threading.Thread(target=mc_functions.get(cmd, chat), args=tuple(args[1:]), kwargs={}).start()
        self.request.sendall("ok".encode('utf-8'))

if __name__ == "__main__":
    server = socketserver.TCPServer((HOST, PORT), MyTCPHandler)
    def server_serve():
        while keep_running():
            server.handle_request()
    threading.Thread(target=server_serve).start()

P_Mis

13.09.19 — 14:39

P_Mis

1 — 13.09.19 — 14:57

В первый раз появилось на платформе 8.3.14.1854, после этого откатились на 8.3.12.1685, на которой были несколько месяцев, ситуация не изменилась.

eklmn

2 — 13.09.19 — 15:53

P_Mis

3 — 13.09.19 — 16:03

(2) Так какие настройки? На РДП сервере стоит только тонкий клиент, какие и где там настройки можно сбросить?

fbear

4 — 13.09.19 — 16:05

P_Mis

5 — 13.09.19 — 16:16

(4) Все эти настройки сделаны, это все как раз гуглится по ошибке «Обычно разрешается одно использование адреса сокета (протокол/сетевой адрес/порт)». Но легче не стало вообще. Да и 80 пользователей не так много.

P_Mis

6 — 13.09.19 — 16:17

Проблема в том, что тонкий клиент почему-то занимает 1560-1591 порты на рдп сервере (не на 1С сервере) и из-за этого не могут подключаться новые клиенты. Так как если через netstat выбрать клиента, который занял 1560 порт, завершить его, то другой пользователь сможет зайти.

Fragster

7 — 13.09.19 — 16:19

кто-то подкрутил параметр количество соединений на процесс?

Fragster

8 — 13.09.19 — 16:19

сколько rphost на сервере?

P_Mis

9 — 13.09.19 — 16:27

Fragster

10 — 13.09.19 — 17:59

режим отладки при запуске клиента?

P_Mis

11 — 13.09.19 — 18:43

(10) О, интересная мысль, надо будет проверить. Вообще запускается все без отладки, но вдруг каким-то образом она включается…

P_Mis

12 — 13.09.19 — 18:46

(10) (11) Во блин, точно! На одном из клиентов, который занял 1562 порт запущена отладка. Каким образом она могла включиться сама то?

P_Mis

13 — 16.09.19 — 11:25

(13) Соответственно решение это в личных настройках пользователей очистить настройку из закладки Прочие настройки — Прочие настройки. Ну и переписать копирование настроек, если это делается автоматом.

Полагаю, некоторые коллеги уже оказывались в ситуации, когда отладка внезапно пропадала, и различные «шаманские» методики (переустановка платформы, чистка локального кэша и прочее) результата не давали. Опишу свой опыт по выявлению и устранению причины.

<config xmlns="http://v8.1c.ru/v8/tech-log">
<log location="C:v8clientlogs" history="1">
<event>
<ne property="name" value=""/>
</event>
<property name="all">
</property>
</log>
</config>

30:25.862000-0,EXCP,1,process=1cv8,ClientID=0,Exception=NetDataExchangeException,Descr='server_addr=any:1560 descr=10048(0x00002740): Обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт). line=261 file=srcDataExchangeServerImpl.cpp'
30:25.862003-0,EXCP,1,process=1cv8,ClientID=0,Exception=NetDataExchangeException,Descr='server_addr=any:1561 descr=10048(0x00002740): Обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт). line=261 file=srcDataExchangeServerImpl.cpp'
30:25.862006-0,EXCP,1,process=1cv8,ClientID=0,Exception=NetDataExchangeException,Descr='server_addr=any:1562 descr=10048(0x00002740): Обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт). line=261 file=srcDataExchangeServerImpl.cpp'
30:30.199000-0,EXCP,3,process=1cv8,Usr=Админ,ClientID=3,Exception=NetDataExchangeException,Descr='server_addr=tcp://127.0.0.1:1562 descr=127.0.0.1:1562:10060(0x0000274C): Попытка установить соединение была безуспешной, т.к. от другого компьютера за требуемое время не получен нужный отклик, или было разорвано уже установленное соединение из-за неверного отклика уже подключенного компьютера. ;
line=1043 file=srcDataExchangeTcpClientImpl.cpp'
30:34.208000-0,EXCP,3,process=1cv8,Usr=Админ,ClientID=4,Exception=NetDataExchangeException,Descr='server_addr=tcp://127.0.0.1:1562 descr=127.0.0.1:1562:10060(0x0000274C): Попытка установить соединение была безуспешной, т.к. от другого компьютера за требуемое время не получен нужный отклик, или было разорвано уже установленное соединение из-за неверного отклика уже подключенного компьютера. ;
line=1043 file=srcDataExchangeTcpClientImpl.cpp'

Понимаю, что тем с таким заголовком уже уйма, но ответа я так и не увидел. А точнее — что делать в моем случае.

Итак, делаю сервер, который слушает локалку по указанному порту. За основу взял эту библиотеку — https://github.com/nterry/AwesomeSockets.
Вот так выглядит метод запуска прослушивания:

public async void StartListening(int port)
{
if (CancellationTokenSource == null)
CancellationTokenSource = new CancellationTokenSource();
_cancellationToken = CancellationTokenSource.Token;
Clients = new ObservableCollection<Client>();
BindingOperations.EnableCollectionSynchronization(Clients, _lockObject);
try
{
while (_tcpListen == null)
{
ShowCallbackMessageAction?.Invoke("Try to start server");
_tcpListen = AweSock.TcpListen(port);
if (_tcpListen != null)
{
ShowCallbackMessageAction?.Invoke("Server started");
var waitForConnectionTask = Task.Run(() => WaitForConnectionLoop(), _cancellationToken);
var checkClientsConnectionTask = Task.Run(() => CheckClientsConnectionLoop(), _cancellationToken);
await Task.WhenAll(waitForConnectionTask, checkClientsConnectionTask);
}
// https://stackoverflow.com/a/32768637/4944499
await Task.Delay(1000, _cancellationToken).ContinueWith(task => { });
}
}
catch (Exception exception)
{
ShowCallbackMessageAction?.Invoke($"Error on start server: {exception.Message}");
}
}

Вот так метод остановки прослушивания:

public void StopListening()
{
ShowCallbackMessageAction?.Invoke("Begin stop server...");
ShowCallbackMessageAction?.Invoke("Disconnect all clients");
DisconnectAllClients();
CancellationTokenSource?.Cancel();
_tcpListen?.Close();
_tcpListen = null;
ShowCallbackMessageAction?.Invoke("Server stopped");
}

Метод из библиотеки, вызываемый в моем методе StartListening:

public static ISocket TcpListen(int port, int backlog = 10)
{
var listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
//var ip = new IPAddress(new byte[] { 0, 0, 0, 0 });
//var localEndPoint = new IPEndPoint(ip, port);
IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, port);
listenSocket.Bind(localEndPoint);
listenSocket.Listen(backlog);
return AwesomeSocket.New(listenSocket);
}

Так вот — это все работает до того момента, пока я приложение свое не закрою без отписки от прослушивания. Т.е., например, случился крэш. После того, как я повторно запускаю сервер, то вижу сообщение:

Везде пишут, что это нормально и порт сам освободится через некоторое время (вроде 240 секунд), но в моем случае этого не происходит. Помогает только перезагрузка компа.
Как быть?