標籤彙整: 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數據實例