标签汇整: C

C语言中的localtime被多次使用引发的思考

　　今天写某个程式时，出现一个奇妙的问题，输出的时间戳总是不正确，查了半天百思不得其解。我把出问题的代码简化成下面的形式：

#include<iostream>
#include<time.h>
using namespace std;

int main(int argc, char *argv[])
{
	time_t curr_time;
	curr_time = time(NULL);//得到当前Unix时间戳
	struct tm *now;
	now = localtime(&curr_time);//转换成年月日时分秒到结构体中
	printf("debug1::%04d%02d%02d\n",now->tm_year+1900,now->tm_mon+1,now->tm_mday);//目前是8月18日

	time_t lastmon_t = curr_time - 1728000;//目前时间前推20天,应该得到的结果是7月29日的时间戳
	struct tm *las;
	las = localtime(&lastmon_t);
	printf("debug2::%04d%02d%02d\n",now->tm_year+1900,now->tm_mon+1,now->tm_mday);//输出now结构体的时间
	printf("debug3::%04d%02d%02d\n",las->tm_year+1900,las->tm_mon+1,las->tm_mday);//输出las结构体的时间

	getchar();
	return 0;
}

#include<iostream>

#include<time.h>

using namespace std;

int main(int argc, char *argv[])

{

time_t curr_time;

curr_time = time(NULL);//得到当前Unix时间戳

struct tm *now;

now = localtime(&curr_time);//转换成年月日时分秒到结构体中

printf("debug1::%04d%02d%02d\n",now->tm_year+1900,now->tm_mon+1,now->tm_mday);//目前是8月18日

time_t lastmon_t = curr_time - 1728000;//目前时间前推20天,应该得到的结果是7月29日的时间戳

struct tm *las;

las = localtime(&lastmon_t);

printf("debug2::%04d%02d%02d\n",now->tm_year+1900,now->tm_mon+1,now->tm_mday);//输出now结构体的时间

printf("debug3::%04d%02d%02d\n",las->tm_year+1900,las->tm_mon+1,las->tm_mday);//输出las结构体的时间

getchar();

return 0;

}

输出结果是：
debug1::20160818
debug2::20160729
debug3::20160729

　　debug2和debug3的位置本想分别输出目前的时间now和前推的时间las，而结果并没有符合预想。看了看代码，在前一次debug1输出now，和后一次debug2输出now之间，并没有对结构体now做任何赋值操作，而now的内容却改变成了和las一样的。
　　这个问题让我百思不得其解，怎么看我都没有对now进行操作，唯一的解释就是now和las指针指向的是同一个地址。最后不断的测试缩小范围，把问题锁定到localtime()上。于是上网查询了一下localtime()的文档，发现localtime()不仅不是线程安全的函数，不建议使用，而且只能同时使用一次，因为localtime()不是可重入的。
　　所以说我的now和las确实指向了同一个地址，因为我是在Linux下编译的所以并没有提示，如果在VS下编译就会看见localtime()不是线程安全函数的提示。于是我从网上找到了libc提供的另一个函数localtime_r()，修改程序如下：

#include<iostream>
#include<time.h>
using namespace std;

int main(int argc, char *argv[])
{
	time_t curr_time;
	curr_time = time(NULL);//得到当前Unix时间戳
	struct tm now;
	localtime_r(&curr_time,&now);//转换成年月日时分秒到结构体中
	printf("debug1::%04d%02d%02d\n",now.tm_year+1900,now.tm_mon+1,now.tm_mday);//目前是8月18日

	time_t lastmon_t = curr_time - 1728000;//目前时间前推20天,应该得到的结果是7月29日的时间戳
	struct tm las;
	localtime_r(&lastmon_t,&las);
	printf("debug2::%04d%02d%02d\n",now.tm_year+1900,now.tm_mon+1,now.tm_mday);//输出now结构体的时间
	printf("debug3::%04d%02d%02d\n",las.tm_year+1900,las.tm_mon+1,las.tm_mday);//输出las结构体的时间

	getchar();
	return 0;
}

#include<iostream>

#include<time.h>

using namespace std;

int main(int argc, char *argv[])

{

time_t curr_time;

curr_time = time(NULL);//得到当前Unix时间戳

struct tm now;

localtime_r(&curr_time,&now);//转换成年月日时分秒到结构体中

printf("debug1::%04d%02d%02d\n",now.tm_year+1900,now.tm_mon+1,now.tm_mday);//目前是8月18日

time_t lastmon_t = curr_time - 1728000;//目前时间前推20天,应该得到的结果是7月29日的时间戳

struct tm las;

localtime_r(&lastmon_t,&las);

printf("debug2::%04d%02d%02d\n",now.tm_year+1900,now.tm_mon+1,now.tm_mday);//输出now结构体的时间

printf("debug3::%04d%02d%02d\n",las.tm_year+1900,las.tm_mon+1,las.tm_mday);//输出las结构体的时间

getchar();

return 0;

}

输出结果是：
debug1::20160818
debug2::20160818
debug3::20160729

　　于是问题解决了，还有要注意的是，Windows下并没有localtime_r，与其相同的函数是localtime_s。

======
kujou_rin

C语言socket编程发送HTTP请求实例

发布留言

前几天在自己的私服中用c写了一个模拟股市系统，所使用的数据是通过socket发送HTTP请求，然后获得新浪财经的接口页面进行处理。那么现在我们把需求和需要做的事情总结一下：
1、如何发送HTTP请求
2、请求到某个股票网站的输入和输出分别是什么
3、处理收到的字符串数据

先试着写一个简单的HTTP请求发送和接收程序

#include<stdio.h>
#include<string.h>
#include<stdlib.h>
#include<unistd.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<netdb.h>

int main(int argc,char *argv[])
{
	char urlstr[8096];
	char buf[8096];
	struct hostent *server;

	//创建套接字
	int fd=socket(AF_INET,SOCK_STREAM,0);
	if(fd==-1) printf("sockett err:%m\n"),exit(-1);
	printf("socket ok!\n");
	struct sockaddr_in addr;
	addr.sin_family=AF_INET;
	addr.sin_port=htons(80);
	//解析域名
	server = gethostbyname("hq.sinajs.cn");
	//连接
	memcpy((char *)&addr.sin_addr.s_addr,(char*)server->h_addr, server->h_length);
	int r=connect(fd,(struct sockaddr*)&addr,sizeof addr);
	if(r==-1) printf("connect err:%m\n"),exit(-1);
	printf("connect ok!\n");
	//发送HTTP请求
	sprintf(urlstr,"GET /?list=sh600000  HTTP/1.1\r\nHost: hq.sinajs.cn\r\nConnection: Close\r\n\r\n");
	write(fd,urlstr,strlen(urlstr));
	//接收并打印
	r=recv(fd,buf,8096,0);
	if(r<=0) {close(fd);return -1;}
	buf[r]=0;
	printf("%s",buf);
	//关闭套接字
	close(fd);
	return 0;
}

#include<stdio.h>

#include<string.h>

#include<stdlib.h>

#include<unistd.h>

#include<sys/socket.h>

#include<netinet/in.h>

#include<arpa/inet.h>

#include<netdb.h>

int main(int argc,char *argv[])

{

char urlstr[8096];

char buf[8096];

struct hostent *server;

//创建套接字

int fd=socket(AF_INET,SOCK_STREAM,0);

if(fd==-1) printf("sockett err:%m\n"),exit(-1);

printf("socket ok!\n");

struct sockaddr_in addr;

addr.sin_family=AF_INET;

addr.sin_port=htons(80);

//解析域名

server = gethostbyname("hq.sinajs.cn");

//连接

memcpy((char *)&addr.sin_addr.s_addr,(char*)server->h_addr, server->h_length);

int r=connect(fd,(struct sockaddr*)&addr,sizeof addr);

if(r==-1) printf("connect err:%m\n"),exit(-1);

printf("connect ok!\n");

//发送HTTP请求

sprintf(urlstr,"GET /?list=sh600000 HTTP/1.1\r\nHost: hq.sinajs.cn\r\nConnection: Close\r\n\r\n");

write(fd,urlstr,strlen(urlstr));

//接收并打印

r=recv(fd,buf,8096,0);

if(r<=0) {close(fd);return -1;}

buf[r]=0;

printf("%s",buf);

//关闭套接字

close(fd);

return 0;

}

上面的例子使用非阻塞的recv作为接收，优点是接收后不会阻塞的运行程序进行接下来的输出打印，而缺点是如果返回的页面数据很多，分包之后会发现recv接收的页面是不全的，只有大概2k多数据。所以在实际应用中我使用了read作为接收函数。

我的需求是通过上证股票代码获得开盘收盘和当前价格等信息，已知新浪股票的HTTP接口用法是这样 http://hq.sinajs.cn/?list=sh600000,sh600406 放到浏览器一看就明白了，已经满足通过代码获的所有信息，接下来写具体的处理过程。

下面是我所写的通过股票代码获得实时价格的程序：

#include<iostream>
#include<sstream>
#include<string.h>
#include<time.h>
#include<stdlib.h>
#include<unistd.h>
#include<mysql/mysql.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<netdb.h>
using namespace std;

int s_num = 5;
char stock[][10]={"000001","600000","600005","600006","600007"};
// 上证指数,浦发银行,武钢股份,东风汽车,中国国贸

int main(int argc,char *argv[])
{
	time_t tval;
	struct tm *now;
	tval = time(NULL);
	now = localtime(&tval);
	char str[1024];
	int i;
	double d;
	int i1;
	char ch;

	MYSQL my_connection;
	MYSQL_RES *result;
	MYSQL_ROW row;
	mysql_init(&my_connection);

	struct hostent *server;
	stringstream sstr,recvstr;
	char strss[1024];
	char zd[33][50];

	int fd=socket(AF_INET,SOCK_STREAM,0);
	if(fd==-1) printf("sockett err:%m\n"),exit(-1);
	printf("socket ok!\n");
	struct sockaddr_in addr;
	addr.sin_family=AF_INET;
	addr.sin_port=htons(80);
	server = gethostbyname("hq.sinajs.cn");
	memcpy((char *)&addr.sin_addr.s_addr,(char*)server->h_addr, server->h_length);
	int r=connect(fd,(struct sockaddr*)&addr,sizeof addr);
	if(r==-1) printf("connect err:%m\n"),exit(-1);
	printf("connect ok!\n");

	//同时获得多个个股信息
	sstr << "GET /?list=";
	for (i=0; i<s_num; i++)
	{
		sstr << "sh";
		sstr << stock[i];
		if (i != s_num-1)
			sstr << ",";
	}
	sstr << " HTTP/1.1\r\nHost: hq.sinajs.cn\r\nConnection: Close\r\n\r\n";
	cout << "debug:" << sstr.str();
	write(fd,sstr.str().c_str(),sstr.str().length());

		//阻塞read一直读取直到fd被超时关闭
	while(read(fd,&ch,1))
	{
		recvstr << ch;
	}
	close(fd);
	cout << recvstr.str() << endl;
	//因为本人习惯于使用stream类型保存便于以后getline和处理

	if (mysql_real_connect(&my_connection, "0.0.0.0","user", "passwd", "datadb", 0, NULL, 0))
	{
		printf("[%04d%02d%02d%02d%02d%02d] Connection success\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);
	}
	else
	{
		printf("[%04d%02d%02d%02d%02d%02d] Connection failed\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);
		return -1;
	}

	recvstr.getline(strss, 1024);
	i = 0;
	while(!recvstr.eof()&&!recvstr.fail())
	{
		if((strstr(strss,"var hq_str_sh") != NULL) && (strstr(strss,stock[i]) != NULL))
		{
		//======数据库处理过程已省略======

		//======数据库处理过程已省略======
			i++;
		}
		if (i == s_num) break;
		memset(strss, 0x00, 1024);
		recvstr.getline(strss, 1024);
	}
	mysql_close(&my_connection);
	return 0;
}

100

101

#include<iostream>

#include<sstream>

#include<string.h>

#include<time.h>

#include<stdlib.h>

#include<unistd.h>

#include<mysql/mysql.h>

#include<sys/socket.h>

#include<netinet/in.h>

#include<arpa/inet.h>

#include<netdb.h>

using namespace std;

int s_num = 5;

char stock[][10]={"000001","600000","600005","600006","600007"};

// 上证指数,浦发银行,武钢股份,东风汽车,中国国贸

int main(int argc,char *argv[])

{

time_t tval;

struct tm *now;

tval = time(NULL);

now = localtime(&tval);

char str[1024];

int i;

double d;

int i1;

char ch;

MYSQL my_connection;

MYSQL_RES *result;

MYSQL_ROW row;

mysql_init(&my_connection);

struct hostent *server;

stringstream sstr,recvstr;

char strss[1024];

char zd[33][50];

int fd=socket(AF_INET,SOCK_STREAM,0);

if(fd==-1) printf("sockett err:%m\n"),exit(-1);

printf("socket ok!\n");

struct sockaddr_in addr;

addr.sin_family=AF_INET;

addr.sin_port=htons(80);

server = gethostbyname("hq.sinajs.cn");

memcpy((char *)&addr.sin_addr.s_addr,(char*)server->h_addr, server->h_length);

int r=connect(fd,(struct sockaddr*)&addr,sizeof addr);

if(r==-1) printf("connect err:%m\n"),exit(-1);

printf("connect ok!\n");

//同时获得多个个股信息

sstr << "GET /?list=";

for (i=0; i<s_num; i++)

{

sstr << "sh";

sstr << stock[i];

if (i != s_num-1)

sstr << ",";

}

sstr << " HTTP/1.1\r\nHost: hq.sinajs.cn\r\nConnection: Close\r\n\r\n";

cout << "debug:" << sstr.str();

write(fd,sstr.str().c_str(),sstr.str().length());

//阻塞read一直读取直到fd被超时关闭

while(read(fd,&ch,1))

{

recvstr << ch;

}

close(fd);

cout << recvstr.str() << endl;

//因为本人习惯于使用stream类型保存便于以后getline和处理

if (mysql_real_connect(&my_connection, "0.0.0.0","user", "passwd", "datadb", 0, NULL, 0))

{

printf("[%04d%02d%02d%02d%02d%02d] Connection success\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);

}

else

{

printf("[%04d%02d%02d%02d%02d%02d] Connection failed\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);

return -1;

}

recvstr.getline(strss, 1024);

i = 0;

while(!recvstr.eof()&&!recvstr.fail())

{

if((strstr(strss,"var hq_str_sh") != NULL) && (strstr(strss,stock[i]) != NULL))

{

//======数据库处理过程已省略======

i++;

}

if (i == s_num) break;

memset(strss, 0x00, 1024);

recvstr.getline(strss, 1024);

}

mysql_close(&my_connection);

return 0;

}

由于涉及自己服务器数据库的数据结构，数据库处理过程已经省略。getline得到的每一行可以用sscanf分隔成字符串，然后再使用atof转化为价格数的浮点。引号内的字段可以分别保存到zd[33][50]的二位数组中，关于新浪的股票接口，它们每个字段表示的意义大概如下：
0股票名称；1今开价；2昨收价；3当前价；4今最高；5今最低；……最后是30更新日期和31时间

自用程序写的比较烂，如有缺陷欢迎指正。
=======
kujou_rin

C语言接口远程读取MySQL数据实例

2 则留言

　　之前在服务器上搭建了VPN之后，顺便写了一个php的注册页面用于注册VPN的用户，使用MySQL保存用户数据。而pptpd和l2tpd服务则在另一台服务器运行，且通过文件进行用户验证。因此需要将用户密码表单远程从MySQL中取出并在VPN服务器保存为文件。我的解决方案是使用C语音调用MySQL接口然后使用文件流保存，这样的方案同样可用于解决架设多节点的VPN服务。

实例代码如下：

#include<iostream>
#include<fstream>
#include<time.h>
#include<unistd.h>
#include<mysql/mysql.h>

using namespace std;

int main(int argc,char *argv[])
{
	//获取当前时间
	time_t tval;
	struct tm *now;
	tval = time(NULL);
	now = localtime(&tval);
	char str[500];
	int i;

	MYSQL my_connection;
	MYSQL_RES *result;
	MYSQL_ROW row;
	int res;
	mysql_init(&my_connection);
	//创建MySQL连接
	if (mysql_real_connect(&my_connection, "88.88.88.88","user", "password", "database", 0, NULL, 0)) //在此确认您的SQL服务器地址，用户名，密码，库实例名称
	{
		//前台运行时输出连接数据库的时间
		printf("[%04d%02d%02d%02d%02d%02d] Connection success\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);
		//读取有效期大于目前时间的记录
		res = mysql_query(&my_connection, "select userid,user_pass from usertable where validtime > now()");
		if(res == 0)
		{
			//定义文件输出
			ofstream ofs1("./outfile.txt");
			if(!ofs1)
			{
				cout << "Create file failed!" << str << endl;
				mysql_close(&my_connection);
				return 0;
			}
			result = mysql_store_result(&my_connection);
			//从数据库查询结果集中逐条读取记录
			while ((row = mysql_fetch_row(result)))
			{
				//存入文件并打印到前台(输出格式配合chap-secrets
				cout << row[0] << "\t" << "*" << "\t" << row[1] << "\t" << "*" << endl;
				ofs1 << row[0] << "\t" << "*" << "\t" << row[1] << "\t" << "*" << endl;
			}
			ofs1 << endl;
			ofs1.close();
			cout << "write file over." << endl;
			mysql_free_result(result);
		}
		else
		{
			cout << "mysql_query return " << res << endl;
		}
		mysql_close(&my_connection);
	}
	else
	{
		printf("[%04d%02d%02d%02d%02d%02d] Connection failed\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);
	}
	return 0;
}

#include<iostream>

#include<fstream>

#include<time.h>

#include<unistd.h>

#include<mysql/mysql.h>

using namespace std;

int main(int argc,char *argv[])

{

//获取当前时间

time_t tval;

struct tm *now;

tval = time(NULL);

now = localtime(&tval);

char str[500];

int i;

MYSQL my_connection;

MYSQL_RES *result;

MYSQL_ROW row;

int res;

mysql_init(&my_connection);

//创建MySQL连接

if (mysql_real_connect(&my_connection, "88.88.88.88","user", "password", "database", 0, NULL, 0)) //在此确认您的SQL服务器地址，用户名，密码，库实例名称

{

//前台运行时输出连接数据库的时间

printf("[%04d%02d%02d%02d%02d%02d] Connection success\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);

//读取有效期大于目前时间的记录

res = mysql_query(&my_connection, "select userid,user_pass from usertable where validtime > now()");

if(res == 0)

{

//定义文件输出

ofstream ofs1("./outfile.txt");

if(!ofs1)

{

cout << "Create file failed!" << str << endl;

mysql_close(&my_connection);

return 0;

}

result = mysql_store_result(&my_connection);

//从数据库查询结果集中逐条读取记录

while ((row = mysql_fetch_row(result)))

{

//存入文件并打印到前台(输出格式配合chap-secrets

cout << row[0] << "\t" << "*" << "\t" << row[1] << "\t" << "*" << endl;

ofs1 << row[0] << "\t" << "*" << "\t" << row[1] << "\t" << "*" << endl;

}

ofs1 << endl;

ofs1.close();

cout << "write file over." << endl;

mysql_free_result(result);

}

else

{

cout << "mysql_query return " << res << endl;

}

mysql_close(&my_connection);

}

else

{

printf("[%04d%02d%02d%02d%02d%02d] Connection failed\n",now->tm_year+1900, now->tm_mon+1, now->tm_mday, now->tm_hour, now->tm_min, now->tm_sec);

}

return 0;

}

Makefile文件内容如下：

all:
	c++ usercheck.cpp -ousercheck -lmysqlclient

1 2	all: c++ usercheck.cpp -ousercheck -lmysqlclient

然后只需要再写一个shell脚本添加到 crontab 定时运行该程式并将输出的文件移动为 chap-secrets 即可。

#!/bin/sh

cd /home/test/
./usercheck
if [ -f outfile.txt ]
then
mv ./outfile.txt /etc/ppp/chap-secrets
fi

#!/bin/sh

cd /home/test/

./usercheck

if [ -f outfile.txt ]

then

mv ./outfile.txt /etc/ppp/chap-secrets

简易的VPN用户管理系统就大功告成了~

======
kujou_rin

九条凛の部屋

Kujou Rin's Blog | Lilith Project

标签汇整: C

C语言中的localtime被多次使用引发的思考

C语言socket编程发送HTTP请求实例

C语言接口远程读取MySQL数据实例