65 lines
1.5 KiB
C
65 lines
1.5 KiB
C
|
//
|
||
|
|
// 气象信息客户端
|
||
|
|
// 连接SUB套接字至tcp://*:5556端点
|
||
|
|
// 收集指定邮编的气象信息，并计算平均温度
|
||
|
|
//
|
||
|
|
#include "zhelpers.h"
|
||
|
|
|
||
|
|
struct Msg
|
||
|
|
{
|
||
|
|
int stat;
|
||
|
|
char id[100];
|
||
|
|
};
|
||
|
|
|
||
|
|
int main (int argc, char *argv [])
|
||
|
|
{
|
||
|
|
/*
|
||
|
|
struct Msg msg;
|
||
|
|
msg.stat = 1;
|
||
|
|
const char *str = "hellow world!";
|
||
|
|
memset(msg.id, 0, sizeof(msg.id));
|
||
|
|
memcpy(msg.id, str, strlen(str));
|
||
|
|
int len = sizeof(struct Msg);
|
||
|
|
printf("sizeofid = %d strlen = %d len = %d\n", sizeof(msg.id), strlen(str), len);
|
||
|
|
*/
|
||
|
|
|
||
|
|
const char* param = NULL;
|
||
|
|
if (argc > 1)
|
||
|
|
{
|
||
|
|
param = argv[1];
|
||
|
|
}
|
||
|
|
else
|
||
|
|
{
|
||
|
|
printf("connect where: ip/port!\n");
|
||
|
|
}
|
||
|
|
|
||
|
|
char addr[40];
|
||
|
|
sprintf(addr, "tcp://%s", param);
|
||
|
|
|
||
|
|
void *context = zmq_init (1);
|
||
|
|
|
||
|
|
printf ("正在收集气象信息...\n");
|
||
|
|
void *subscriber = zmq_socket (context, ZMQ_SUB);
|
||
|
|
zmq_connect (subscriber, addr);
|
||
|
|
|
||
|
|
char *filter = "0";
|
||
|
|
zmq_setsockopt (subscriber, ZMQ_SUBSCRIBE, filter, strlen (filter));
|
||
|
|
|
||
|
|
int update_nbr;
|
||
|
|
for (update_nbr = 0; update_nbr < 100; update_nbr++) {
|
||
|
|
char *string = s_recv (subscriber);
|
||
|
|
printf("string=%s %d \n", string ,strlen(string));
|
||
|
|
int protocol_serial = 0;
|
||
|
|
int len = 0;
|
||
|
|
struct Msg msg;
|
||
|
|
sscanf (string, "%d|%d|%d|%s", &protocol_serial, &msg.stat, &len, msg.id);
|
||
|
|
printf("recv ps=%d stat=%d len=%d id=%s\n",
|
||
|
|
protocol_serial, msg.stat, len, msg.id);
|
||
|
|
free (string);
|
||
|
|
}
|
||
|
|
|
||
|
|
zmq_close (subscriber);
|
||
|
|
zmq_term (context);
|
||
|
|
return 0;
|
||
|
|
}
|