#include "zhelpers.h"

struct Msg
{
	int stat;
	char id[100];
};
 
int main (int argc, char *argv [])
{
	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);

    	//  准备上下文和PUB套接字
    	void *context = zmq_init (1);
    	void *publisher = zmq_socket (context, ZMQ_PUB);
    	zmq_bind (publisher, addr);
    	//zmq_bind (publisher, "ipc://weather.ipc");
 
    	//  初始化随机数生成器
    	srandom ((unsigned) time (NULL));
    	while (1) {
        	//  生成数据
        	int protocol_serial;
        	protocol_serial = randof (1);
 
        	char buf [200];
		size_t buf_len = 0;

		memset(buf, 0, sizeof(buf));
		printf("buf: %d %s\n", strlen(buf), buf);

		struct Msg msg;
		msg.stat = 0;
		const char * str = "aa";
		memcpy(msg.id, str, strlen(str));

        	sprintf (buf, "%d|%d|%d|%s", protocol_serial, msg.stat, strlen(msg.id), msg.id);

		printf("buf: %d %s\n", strlen(buf), buf);
		printf("send %d %d %d %s --> %s \n", protocol_serial, msg.stat, strlen(msg.id), buf, addr);
        	s_send (publisher, buf);
		sleep(2);
    	}
    	zmq_close (publisher);
    	zmq_term (context);
    	return 0;
}