6

关于守则

我EasyModbus Nuget在 C# 窗口窗体应用程序中使用。我正在尝试使用 RTU（实时更新）获取更改后的保持寄存器的地址值ModbusServer。

下面的代码连接到服务器。

void Connect() {
    ModbusClient client = null;
    client = new ModbusClient("IP Address", 502);
    client.Connect();
}

下面的代码获取保持寄存器下面给出的地址值。

client.ReadHoldingRegisters(10001, 1);

到目前为止，一切正常。

我正在阅读有关 EasyModbus 中实时更新的信息。我发现这个链接可以自动将更改后的保持寄存器值发送到偶数处理程序。

现在，我有以下代码： 

void Connect() {
    ModbusServer ser = new ModbusServer();
    ser.Port = Convert.ToInt32(Settings.Default.Port);
    ser.Listen();
    ser.HoldingRegistersChanged += Ser_HoldingRegistersChanged;

    ModbusClient client = null;
    client = new ModbusClient("IP Address", 502);
    client.Connect();
}


private void Ser_HoldingRegistersChanged(int register, int numberOfRegisters)
{
}

当我运行它时，我得到以下错误。

每个套接字地址（协议/网络地址/端口）通常只允许使用一次

发生此错误是因为我添加了 ModbusServer 代码。

你能建议为什么会这样吗？

4

2 回答 2

3

你的问题不是那么严重，你的主要问题在这一行

ser.Listen();

因为您以前的服务器套接字仍在绑定中。

让我们看看监听套接字何时绑定？

明显的原因是当您的侦听套接字发送/接收数据包时，但在极少数情况下，当操作系统不处于理想状态（100 % cpu 使用率等）时会发生这种情况，然后释放服务器套接字可能需要一分钟才能释放。在这种情况下，当您再次运行服务器时，异常

每个套接字地址（协议/网络地址/端口）通常只允许使用一次

发生。因为，正如我之前所说的，之前的服务器套接字还没有发布。

解决方案是

为不同的服务器套接字使用不同的端口

或者

仅使用一个仅启动一次的服务器套接字并检查它是否已连接。

// create the socket
public static Socket listenSocket = new Socket(AddressFamily.InterNetwork, 
                                        SocketType.Stream,
                                        ProtocolType.Tcp);

// bind the listening socket to the port
IPAddress hostIP = (Dns.Resolve(IPAddress.Any.ToString())).AddressList[0];
IPEndPoint ep = new IPEndPoint(hostIP, port);
if(!listenSocket.IsBound){
  listenSocket.Bind(ep);     
  // start listening
  listenSocket.Listen(backlog);
}
// connect client 
ModbusClient client = null;
client = new ModbusClient(hostIP , port);
client.Connect();
于 2019-09-22T22:28:48.357 回答
1

看来您的端口上已经有一个服务器，您尝试再添加一个。试试下面的代码：

public partial class Form1 : Form
{
    private int register = 0;
    private readonly int port = 502;
    private readonly List<ModbusServer> servers = new List<ModbusServer>();
    private readonly List<ModbusClient> clients = new List<ModbusClient>();

    public Form1()
    {
        InitializeComponent();
        AppDomain.CurrentDomain.FirstChanceException +=
            (sender, e) => MessageBox.Show(e.Exception.Message);
    }

    private void Foo(object sender, ThreadExceptionEventArgs e)
    {
        MessageBox.Show(e.Exception.Message);
    }

    private void Ser_HoldingRegistersChanged(int register, int numberOfRegisters) =>
        MessageBox.Show($"register: {register}, numberOfRegisters: {numberOfRegisters}");

    private void AddServer_Click(object sender, EventArgs e) =>
        AddServerMethod();

    private void AddClient_Click(object sender, EventArgs e) =>
        AddClientMethod();

    private void AddServerMethod()
    {
        var server = new ModbusServer { Port = port };
        server.Listen();
        server.HoldingRegistersChanged += Ser_HoldingRegistersChanged;
        servers.Add(server);
        MessageBox.Show("Server added.");
        server.holdingRegisters[0] = 11; // register is changed, but no event is fired
    }

    private void AddClientMethod()
    {
        var client = new ModbusClient("127.0.0.1", port);
        client.Connect();
        clients.Add(client);
        MessageBox.Show("Client added.");
        client.WriteSingleRegister(register++, 11); // event is fired
    }
}

在此处输入图像描述

如果您AddServer多次单击，则会收到您描述的错误。顺便说一句，如果您在收到另一个错误AddClient之前单击。AddServer添加一台服务器，然后添加任意数量的客户端。每个客户端写入一个保持寄存器，相关事件被触发，消息如下：

在此处输入图像描述

于 2019-09-22T22:02:49.287 回答