std::string 判断是否有/n

可以使用std::string的find函数来判断字符串中是否包含"\n"，如果包含则返回该子串的位置，否则返回std::string::npos。具体实现如下所示：

#include <iostream>
#include <string>

int main() {
    std::string str = "hello\nworld";
    if (str.find("\n") != std::string::npos) {
        std::cout << "The string contains \\n." << std::endl;
    } else {
        std::cout << "The string does not contain \\n." << std::endl;
    }
    return 0;
}

输出结果为：

The string contains \n.

相关问题

struct SMS { int index; std::string state; std::string sender; std::string timestamp; std::string message; }; std::vector<SMS> smsList; bool serial_port::serial_port_write_read_at_bySMS(const std::string &at_command, const std::string &resp_prefix, std::vector<SMS>& smsList) { std::vector<std::string> read_lines; bool ret_value = false; pthread_mutex_lock(&read_write_mutex); if (!serial_port_write_at_cmd(at_command.c_str())) { goto END; } while (true) { int index = -1, n = -1; char state[32] = {}, phone_num[32] = {}, phone_time[64] = {}; read_lines = serial_port_read_multiple_lines(); for (size_t i = 0; i < read_lines.size(); i++) { //LOG_F(INFO, "read one line from serial: %s", read_line); if (read_lines[i].find("AT") != std::string::npos || read_lines[i].find("at") != std::string::npos) { //Do nothing } else if (read_lines[i].find("OK") != std::string::npos) { //LOG_F(INFO, "find final response OK"); ret_value = true; break; } else if (read_lines[i].find("ERROR") != std::string::npos || read_lines[i].find("+CME ERROR") != std::string::npos) { //LOG_F(INFO, "find final response ERROR"); ret_value = false; break; } else if (read_lines[i].find("+CMGL") != std::string::npos) { LOG_F(INFO, "response_data[%d]: %s", i, read_lines[i]); sscanf(read_lines[i], R"(+CMGL: %d,"%s","%s","%s")", &n, state, phone_num, phone_time); LOG_F(INFO, "n: %d, state: %s, phone_num: %s, phone_time: %s", n, state, phone_num, phone_time); SMS sms; index = i; sms.index = index; sms.state = state; sms.sender = phone_num; sms.timestamp = phone_time; if (read_lines[i].find('\n') != std::string::npos) { sms.message = read_lines[i+1]; } smsList.push_back(sms); // break; } else { LOG_F(INFO, "response_data[%d]->message: %s", i, read_lines[i]); // 继续往下读一行 } } if (index == -1) { break; // 未找到新的响应，退出循环 } } END: pthread_mutex_unlock(&read_write_mutex); return ret_value; } 这段代码有问题吗？如何改正

这段代码存在一些问题。以下是一些可能需要改正的问题：

1. 在循环中，`index`变量应该在每次循环开始时被设置为-1，以便判断是否找到了新的响应。目前，`index`只在找到"+CMGL"响应时被设置为有效值，但是没有在未找到新响应时重置为-1。

2. 在读取响应行时，使用`find()`函数来检查字符串是否包含特定内容。这种方法可能导致误判，因为只要字符串中包含目标内容即可，而不需要完全匹配。建议使用`==`运算符进行精确匹配。

3. 在读取短信消息内容时，使用了错误的索引。根据代码中的逻辑，应该是读取`read_lines[i+1]`作为短信消息内容，而不是`read_lines[i]`。

4. 在读取短信消息内容之前，应该先检查索引是否超出了`read_lines`的范围，避免访问越界。

5. 在读取短信消息内容之后，应该将索引设置为下一个未读取的响应行的索引，以便下一次循环时能够正确读取下一个短信。

下面是修改后的代码示例：

bool serial_port::serial_port_write_read_at_bySMS(const std::string &at_command,
                                                  const std::string &resp_prefix,
                                                  std::vector<SMS>& smsList)
{
    std::vector<std::string> read_lines;
    bool ret_value = false;

    pthread_mutex_lock(&read_write_mutex);
    if (!serial_port_write_at_cmd(at_command.c_str()))
    {
        goto END;
    }

    int index = -1; // 初始化索引为-1

    while (true)
    {
        int n = -1;
        char state[32] = {}, phone_num[32] = {}, phone_time[64] = {};

        read_lines = serial_port_read_multiple_lines();

        for (size_t i = 0; i < read_lines.size(); i++)
        {
            // LOG_F(INFO, "read one line from serial: %s", read_lines[i].c_str());
            if (read_lines[i] == "AT" || read_lines[i] == "at")
            {
                // Do nothing
            }
            else if (read_lines[i] == "OK")
            {
                // LOG_F(INFO, "find final response OK");
                ret_value = true;
                break;
            }
            else if (read_lines[i] == "ERROR" || read_lines[i] == "+CME ERROR")
            {
                // LOG_F(INFO, "find final response ERROR");
                ret_value = false;
                break;
            }
            else if (read_lines[i].find("+CMGL") != std::string::npos)
            {
                LOG_F(INFO, "response_data[%zu]: %s", i, read_lines[i].c_str());
                sscanf(read_lines[i].c_str(),
                       R"(+CMGL: %d,"%s","%s","%s")", &n, state, phone_num, phone_time);
                LOG_F(INFO, "n: %d, state: %s, phone_num: %s, phone_time: %s", n, state, phone_num, phone_time);
                SMS sms;
                index = i;
                sms.index = index;
                sms.state = state;
                sms.sender = phone_num;
                sms.timestamp = phone_time;

                if (i + 1 < read_lines.size() && read_lines[i + 1].find('\n') != std::string::npos)
                {
                    sms.message = read_lines[i + 1];
                    index = i + 1; // 设置索引为下一个未读取的响应行的索引
                }

                smsList.push_back(sms);
            }
            else
            {
                LOG_F(INFO, "response_data[%zu]->message: %s", i, read_lines[i].c_str());
                // 继续往下读一行
            }
        }

        if (index == -1)
        {
            break; // 未找到新的响应，退出循环
        }
    }

END:
    pthread_mutex_unlock(&read_write_mutex);
    return ret_value;
}

请注意，此处仅提供了一种修改方案，具体修改还需要根据实际需求和代码逻辑进行调整。

完善代码#include <ros/console.h> #include <ros/ros.h> #include <serial/serial.h> #include <sstream> #include <std_msgs/String.h> #include <std_msgs/Empty.h> #include <std_msgs/ByteMultiArray.h> serial::Serial sp; int main(int argc, char** argv) { ros::init(argc, argv, "serial_port_servos"); ros::NodeHandle nnode; ros::Publisher read_pub = nnode.advertise<std_msgs::String>("hex_values", 1000); serial::Timeout to = serial::Timeout::simpleTimeout(100); // 设置要打开的串口名称 sp.setPort("/dev/ttyUSB0"); // 设置串口通信的波特率 sp.setBaudrate(9600); // 串口设置timeout sp.setTimeout(to); try { // 打开串口 sp.open(); } catch(serial::IOException& e) { ROS_ERROR_STREAM("Unable to open port."); return -1; } // 判断串口是否打开成功 if(sp.isOpen()) { ROS_INFO_STREAM("/dev/ttyUSB0 is opened."); } else { return -1; } ros::Rate loop_rate(500); while(ros::ok()) { byte[] dataBuffer; int[] hexArray; std::stringstream ss; // 获取缓冲区内的字节数 size_t n = sp.available(); if(n != 0) { ROS_INFO_STREAM("Reading from serial port"); uint8_t buffer[2048]; // 读出数据 n = sp.read(buffer, n); dataBuffer = new byte[1024]; hexArray = new int[1024]; for(int i = 0; i < n; i++) { hexArray[i] = dataBuffer[i].Tostring("X2"); } /*for(int i = 0; i < n; i++) { // 16进制ROS发布 ss << std::setfill('0') << std::setw(2) << std::hex << (buffer[i] & 0xff) << " "; // 16进制打印到屏幕 std::cout <<std::setfill('0') << std::setw(2) << std::hex << (buffer[i] & 0xff) << " "; }*/ std::cout << std::endl; std_msgs::String msg; msg.data = ss.str(); read_pub.publish(msg); ros::spinOnce(); loop_rate.sleep(); } } // 关闭串口 sp.close(); return 0; }

这段代码是用于读取串口数据并将其转换成16进制格式后发布到ROS话题上的。下面是一些需要注意的地方：

1. 在while循环中定义的byte[] dataBuffer和int[] hexArray数组应该在while循环之外定义。否则，每次循环都会重新定义并分配内存，这会降低代码的效率。

2. 在使用dataBuffer数组的时候，应该先将读取到的数据存储在dataBuffer数组中，然后再将其转换为16进制格式并存储在hexArray数组中。目前的代码中，直接将dataBuffer数组中的数据转换为16进制格式，这是错误的。

3. 在将hexArray数组中的数据转换为字符串格式并发布到ROS话题上时，应该使用std::stringstream类来进行格式化操作。当前的代码中，直接使用了std::cout输出到屏幕上。

4. 在while循环中，应该先读取数据再进行循环处理。当前的代码中，先进行循环处理再读取数据，这会导致数据丢失。

下面是修改后的代码：

#include <ros/console.h>
#include <ros/ros.h>
#include #include <serial/serial.h>
#include <sstream>
#include <std_msgs/String.h>
#include <std_msgs/Empty.h>
#include <std_msgs/ByteMultiArray.h>

serial::Serial sp;
byte[] dataBuffer;
int[] hexArray;

int main(int argc, char** argv) {
    ros::init(argc, argv, "serial_port_servos");
    ros::NodeHandle nnode;
    ros::Publisher read_pub = nnode.advertise<std_msgs::String>("hex_values", 1000);
    serial::Timeout to = serial::Timeout::simpleTimeout(100);

    // 设置要打开的串口名称
    sp.setPort("/dev/ttyUSB0");
    // 设置串口通信的波特率
    sp.setBaudrate(9600);
    // 串口设置timeout
    sp.setTimeout(to);

    try {
        // 打开串口
        sp.open();
    } catch(serial::IOException& e) {
        ROS_ERROR_STREAM("Unable to open port.");
        return -1;
    }

    // 判断串口是否打开成功
    if(sp.isOpen()) {
        ROS_INFO_STREAM("/dev/ttyUSB0 is opened.");
    } else {
        return -1;
    }

    // 初始化数组
    dataBuffer = new byte[1024];
    hexArray = new int[1024];

    ros::Rate loop_rate(500);

    while(ros::ok()) {
        // 获取缓冲区内的字节数
        size_t n = sp.available();
        if(n != 0) {
            ROS_INFO_STREAM("Reading from serial port");
            uint8_t buffer[2048];
            // 读出数据
            n = sp.read(buffer, n);

            // 将数据存储在dataBuffer数组中
            for(int i = 0; i < n; i++) {
                dataBuffer[i] = buffer[i];
            }

            // 将dataBuffer数组中的数据转换为16进制格式，并存储在hexArray数组中
            for(int i = 0; i < n; i++) {
                hexArray[i] = dataBuffer[i].Tostring("X2");
            }

            std::stringstream ss;
            // 将hexArray数组中的数据转换为字符串格式，并发布到ROS话题上
            for(int i = 0; i < n; i++) {
                ss << std::setfill('0') << std::setw(2) << std::hex << hexArray[i] << " ";
            }

            std_msgs::String msg;
            msg.data = ss.str();
            read_pub.publish(msg);
        }

        ros::spinOnce();
        loop_rate.sleep();
    }

    // 关闭串口
    sp.close();
    return 0;
}