组件：net/at/at_client功能的一点疑问

发布于 2022-02-18 11:27:28 浏览：1129 订阅该版

针对组件中的at功能的一点疑问，`at_client`的`response`结果判断：

```c
#define AT_RESP_END_OK                 "OK"
#define AT_RESP_END_ERROR              "ERROR"
#define AT_RESP_END_FAIL               "FAIL"
```

判断逻辑：
```c
               else if (rt_memcmp(client->recv_line_buf, AT_RESP_END_OK, rt_strlen(AT_RESP_END_OK)) == 0
                        && resp->line_num == 0)
                {
                    /* get the end data by response result, return response state END_OK. */
                    client->resp_status = AT_RESP_OK;
                }
                else if (rt_strstr(client->recv_line_buf, AT_RESP_END_ERROR)
                        || (rt_memcmp(client->recv_line_buf, AT_RESP_END_FAIL, rt_strlen(AT_RESP_END_FAIL)) == 0))
                {
                    client->resp_status = AT_RESP_ERROR;
                }
                else if (resp->line_counts == resp->line_num && resp->line_num)
                {
                    /* get the end data by response line, return response state END_OK.*/
                    client->resp_status = AT_RESP_OK;
                }
```

但是针对这种期待的应答：

![image.png](https://oss-club.rt-thread.org/uploads/20220218/836d9def9e04742e3f67bceffe3603ce.png)

`“CONNECT”`

代码中没有定义和处理，这种情况怎么使用at_response_t的结果进行判断？需要改组件代码吗？有没有兼容这种情况的使用demo?
谢谢

crystal266 2022-02-18

嵌入式

AT应答消息可以分为三种。
第一种返回 "OK" 或者 "ERROR"，可以按照下面的方式进行解析
```c
if (at_obj_exec_cmd(device->client, resp, "ATE0") != RT_EOK)
{
    result = -RT_ERROR;
    goto __exit;
}
```

第二种返回的除了 "OK" 之外还有其他信息，并且其他信息也需要进行判断，比如说检查SIM卡状态，AT+CPIN? (查看SIM卡的状态)回车，返回：+CPIN：READY  OK(正常)，这种的处理逻辑如下
```c
for (i = 0; i < CPIN_RETRY; i++)
{
    rt_thread_mdelay(1000);
    if (at_obj_exec_cmd(device->client, resp, "AT+CPIN?") == RT_EOK)
    {
        if (at_resp_get_line_by_kw(resp, "READY") != RT_NULL)
            break;
    }
}
```

第三种是服务器主动下发的消息，比如说服务器主动下发的控制信息或者断开连接的消息。这种的处理方法是注册 URC 表，然后收到该类型的消息后就对调用设置的 URC 表的回调函数。
```c
static const struct at_urc urc_table[] =
{
    {"SEND OK",     "\r\n",                 urc_send_func},
    {"SEND FAIL",   "\r\n",                 urc_send_func},
    {"+QIOPEN:",    "\r\n",                 urc_connect_func},
    {"+QIURC:",     "\r\n",                 urc_qiurc_func},
};

int ec200x_socket_init(struct at_device *device)
{
    RT_ASSERT(device);

/* register URC data execution function  */
    at_obj_set_urc_table(device->client, urc_table, sizeof(urc_table) / sizeof(urc_table[0]));

return RT_EOK;
}
```

AT组建的核心逻辑是将收到的 AT 模组的应答信息放到一个环形缓冲区中，然后从这个环形缓冲区中每次读一行数据进行处理，然后判断属于哪一类的消息，调用不同的函数。
**不知道你用的什么模组，常见的模组 rtt 已经写好了驱动代码和 demo，可以直接使用 socket 进行通讯，而不需要关心是怎么执行 AT 指令与模组进行交互的。**

kevinzu 2022-02-18

人认为我，我为人人

kevinzu 2022-02-18

人认为我，我为人人

我的实现：

```
        while (at_exec_cmd(resp, pos->contex.cmd) != RT_EOK  && try_count < 8) {
			
			if (pos->on_response != NULL) {
				if(pos->on_response(0,resp) == REJUDGE_OK) {
					break;
				}
			}

LOG_E("AT client send at commands failed, response error or timeout !");
			
			try_count ++;
			rt_thread_mdelay(1000);
		}

if(try_count >= 8) {
			LOG_E("The number of retransmissions used up !");
			return RT_ERROR;
		}

try_count = 0;

if (pos->on_response != NULL) {
			pos->on_response(1,resp);
		}
```

这条命令定义：

```
{
		.contex = {
			.cmd = "AT+QHTTPURL=70,80\r\n",
			.buf_size = 100,
			.line_num = 2,
			.timeout = 12
		},
		.on_response = on_qhttpurl_response,
		.previous_request = NULL
	}
```

on_qhttpurl_response定义：
```
static int on_qhttpurl_response(int ret,void *param)
{
	at_response_t resp = (at_response_t)param;
	
	if(ret == 1) {
		return 0;
	}

if(resp == NULL) {
		return -1;
	}

if(ret == 0) {
		
		if (at_resp_get_line_by_kw(resp, "CONNECT") != RT_NULL) {
			return REJUDGE_OK;
		}
	}

return 0;
}

```