外贸网站建设电话_住房和城乡建设部政策研究中心_谷歌搜图_优化营商环境发言材料

void *send_data(void *arg)    //这是一个发送数据的线程
{int sockfd = init_tcp_cli("192.168.0.148",50000)  //传ip和port，port == 50000是因为大概前五万都被其它服务所占用，50000后是私人ipif(sockfd < 0){return NULL;}unsigned char pack[128] = {0};int len = 0;while(1){len = pack_net_data(data_g,pack)//data_g是一个保存数据的结构体的全局变量ssize_t size = send(sockfd,pack,len,0)if(size < 0){perror("fail send:");break;    }sleep(1)//这里是为了一秒发送一次数据}close(sockfd);return NULL;
}

初始化cli和包装数据：

int init_tcp_cli(const char *ip,unsigned short port)
{int sockfd = socket(AF_INET,SOCK_STREAM,0)if(sockfd < 0){perror("fail socket:");return -1;}struct sockaddr_in ser;ser.sin_family = AF_INET;ser.sin_port = htons(port);ser.sin_addr.s_addr = inet_addr(ip);int ret = connect(sockfd,(struct sockaddr *)&ser,sizeof(ser));if(ret < 0){perror("fail connect:");return -1;}return sockfd;
}int pack_net_data(Data_t data,unsigned char *pack)
{int i = 0;pack[i++] = 0xAA;         //帧头pack[i++] = 20;           //根据协议确定的有效数据长度memcpy(&pack[i],&data.temp,sizeof(data.temp));  //把数据拷贝到pack中i += sizeof(data.temp);   //下标往后移pack[i++] = data.tim.tm_sec; //把秒数放入pack，因为其它数据的写法都一样，就不写完了for(int j = 1; j < i;++j)  //8位和校验{pack[i] += pack[j];}++i;pack[i] = 0xBB   //帧尾++i;return i;
}