Mysql以及TCP socket的C++代码-526互联

在使用socket编写tcp的C++程序时，遇到了一个问题：

那就bind冲突了，分析原因：是因为std中有bind函数，而socket中也有，但是没有报重复定义的错误，这就有一点难办了。

百度了一下：发现只要使用::bind就可以调用socket的bind。

下面把这个套接字socket的server端代码贴出来：

static void* serverThread(void* pointer)
    {
        ofstream log("connect.txt", std::ios::app);
        pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
        pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
        CarDetect* p_car = (CarDetect*)pointer;
        WSADATA wsdata;
        if (WSAStartup(MAKEWORD(2, 2), &wsdata))
        {
            log << "WAS failed" << endl;
            WSACleanup();
            return FALSE;
        }
        SOCKET s_server, s_accept;
        s_server = socket(PF_INET, SOCK_STREAM, 0);
        if (s_server == INVALID_SOCKET)
        {
            log << "socket failed" << endl;
            WSACleanup();
            return FALSE;
        }
        //填充服务端信息
        SOCKADDR_IN server_addr;
        server_addr.sin_family = AF_INET;
        server_addr.sin_port = htons(8226);
        //当然这里也可以将 127.0.0.1改成你想要的ip或者 INADDR_ANY 为向所有ip发送信息
        server_addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");

        //数据绑定服务器 s_server为服务端套接字
        if (::bind(s_server, (SOCKADDR*)&server_addr, sizeof(SOCKADDR)) == SOCKET_ERROR)
        {
            log << "listen failed" << endl;
            WSACleanup();
            return FALSE;
        }
        if (listen(s_server, 1) == SOCKET_ERROR)
        {
            log << "listen failed" << endl;
            WSACleanup();
            return FALSE;
        }

        sockaddr_in accept_addr;         //用来记录请求连接的套接字信息
        int len = sizeof(SOCKADDR);
        char recv_buf[8192] = { 0 };
        char send_buf[1024] = { 0 };


        while (true)
        {
            //接受连接请求
            s_accept = accept(s_server, (SOCKADDR*)&accept_addr, &len);
            while (true)
            {
                pthread_testcancel();
                int count = p_car->count;
                snprintf(send_buf, sizeof(send_buf), "%s", to_string(count).c_str());
                int sendLen = send(s_accept, (char*)send_buf, sizeof(send_buf), 0);
                if (sendLen < 0) {
                    log << "send failed" << endl;
                    break;
                }
                Sleep(2500);
            }
        }
    }

Mysql的线程也贴一下，注意这个mysql的C++库可以在官网下载：

static void* sqlThread(void* pointer)
    {
        ofstream log("sql.txt", std::ios::app);
        pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
        pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
        CarDetect* p_car = (CarDetect*)pointer;

        mysql_init(&p_car->mysql);   //连接mysql，数据库
        //中间分别是主机，用户名，密码，数据库名，端口号（可以写默认0或者3306等），可以先写成参数再传进去
        const char DataBase_UserName[] = "root";    //数据库用户名username
        const char DataBase_Password[] = "a1234567";   //数据库密码
        const char DataBase_Host[] = "localhost";  //数据库连接地址
        const char DataBase_Name[] = "mysql";  //database name
        unsigned int DataBase_Port = 3306;            //server port

        if (!(mysql_real_connect(&p_car->mysql, DataBase_Host, DataBase_UserName, DataBase_Password, DataBase_Name, DataBase_Port, NULL, DataBase_Port)))
        {
            //TRACE1("Error connecting to database: %s\n", mysql_error(&mysql));
            log << "connect failed" << endl;
            return false;
        }

        while (true)
        {
            pthread_testcancel();
            //string sql_select="SELECT count FROM carcount";
            //vector<vector<wchar_t*>> res=selectData(p_car->mysql,sql_select);
            /*for (int i = 0; i < res.size(); i++)
            {
                for (int j = 0; j < res[i].size(); j++)
                {
                    log << res[i][j] << endl;
                }
            }*/

            //log << _wtoi(res[0][0]) << endl;
            string sql_update = "UPDATE carcount SET count = " + to_string(p_car->count) + ";";
            int ret = mysql_query(&p_car->mysql, sql_update.c_str());
            if (ret)
            {
                log << "update failed" << endl;
            }
            Sleep(5000);
        }
    }

websocket socket http tcp