总线/通信笔记3 —— Modbus TCP 的Server使用_modbus tcp listen

1. libmodbus库的使用

Step 1：初始化RTU/TCP指针

modbus_t *ctx;
ctx = modbus_new_tcp(NULL,502);
1
2

Step 2：初始化变量

在这里插入代码片
1

Step 3：申请内存

mb_mapping = modbus_mapping_new(BITS_ADDRESS + BITS_NB,
                                INPUT_BITS_ADDRESS + INPUT_BITS_NB,
                                REGISTERS_ADDRESS + REGISTERS_NB,
                                INPUT_REGISTERS_ADDRESS + INPUT_REGISTERS_NB);
1
2
3
4

Step 4：监听端口

server_socket = modbus_tcp_listen(ctx,1);
1

Step5：接收数据

modbus_tcp_accept(ctx,&server_socket);
1

Step6：获取查询报文

rc = modbus_receive(ctx,query);
1

Step7：关闭连接

modbus_mapping_free(mb_mapping);
modbus_close(ctx);
modbus_free(ctx);
1
2
3

2. Modbus TCP开发实践

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <iostream>
#include "modbus.h"
#include "config.h"
#define SERVER_ID	1	//从端设备地址

using namespace std;

int main(void)
{
    int server_socket = -1;
    modbus_t *ctx;
    modbus_mapping_t *mb_mapping;
    ctx = modbus_new_tcp(NULL,502);
    modbus_set_debug(ctx,FALSE);

    //modbus_set_slave(ctx,SERVER_ID);

    //申请内存区用于存放寄存器数据
    mb_mapping = modbus_mapping_new(500,500,500,500);
    if(mb_mapping == NULL)
    {
        fprintf(stderr,"Failed mapping:%s\n",modbus_strerror(errno));
        modbus_free(ctx);
        return -1;
    }

    //开始监听端口
    server_socket = modbus_tcp_listen(ctx,1);
    if(server_socket == -1)
    {
        fprintf(stderr,"Unable to listen TCP.\n");
        modbus_free(ctx);
        return -1;
    }


    // 开始接收数据
    modbus_tcp_accept(ctx,&server_socket);

    while(1)
    {
        uint8_t query[MODBUS_TCP_MAX_ADU_LENGTH];
        int rc;

        rc = modbus_receive(ctx,query); //获取查询报文
        if(rc >= 0)
        {
            /* rc is the query size */
            mb_mapping->tab_registers[1] = 2333;   // 将2333写入地址为1的保持寄存器，可简单理解为发送到客户端
            modbus_reply(ctx,query,rc,mb_mapping); // 回复响应报文
            cout<<mb_mapping->tab_registers[0]<<endl;// 打印第一个保持寄存器
        }
        else
        {
            // Connection closed by the client or error
            printf("Connection Closed.\n");

            //Close ctx
            modbus_close(ctx);

            //等待下一个客户端报文
            modbus_tcp_accept(ctx,&server_socket);
        }

    }

    printf("Quit the loop:%s\n",modbus_strerror(errno));

    modbus_mapping_free(mb_mapping);
    modbus_close(ctx);
    modbus_free(ctx);

	return 0;
}


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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80