105 lines
3.0 KiB
C
105 lines
3.0 KiB
C
/*****************************************************************************
|
||
* Copyright: 2016-2026, Ieucd Tech. Co., Ltd.
|
||
* File name: server.c
|
||
* Description: 用于实现zmq多线程收发结构体消息的通信框架。
|
||
* Author: TLSong
|
||
* Version: V0.0.1
|
||
* Date: 2020/7/7
|
||
* History:
|
||
* 2020/7/7 创建文件。
|
||
* *****************************************************************************/
|
||
|
||
#include <zmq.h>
|
||
#include <string.h>
|
||
#include <stdio.h>
|
||
#include <unistd.h>
|
||
#include <assert.h>
|
||
#include <float.h>
|
||
#include <limits.h>
|
||
#include <pthread.h>
|
||
#include "data_mode.h"
|
||
|
||
void *value_server(void *args)
|
||
{
|
||
Msg max_msg = {INT_MAX, CHAR_MAX, SHRT_MAX, LONG_MAX, FLT_MAX, DBL_MAX, "Hello Max Value!"};
|
||
Msg min_msg = {INT_MIN, CHAR_MIN, SHRT_MIN, LONG_MIN, FLT_MIN, DBL_MIN, "Hello Min Value!"};
|
||
Msg random_msg = {233, 'h', 244, 255, 0.01, 0.0001, "Hello Random Value!"};
|
||
|
||
|
||
// Socket to talk to clients
|
||
void *context = zmq_ctx_new ();
|
||
void *responder = zmq_socket (context, ZMQ_REP);
|
||
int rc = zmq_bind (responder, "tcp://*:5555");
|
||
assert (rc == 0);
|
||
|
||
while (1) {
|
||
char buffer [10];
|
||
zmq_recv (responder, buffer, 10, 0);
|
||
printf ("Received: %s\n",buffer);
|
||
sleep (1); // Do some 'work'
|
||
Msg send_msg;
|
||
if(strcmp(buffer,"MAX")==0)
|
||
send_msg = max_msg;
|
||
else if(strcmp(buffer,"MIN")==0)
|
||
send_msg = min_msg;
|
||
else
|
||
send_msg = random_msg;
|
||
zmq_send (responder, &send_msg, sizeof(send_msg), 0);
|
||
printf ("Sned message: \n");
|
||
printf ("---------------start---------------\n");
|
||
printf ("int: %d\n",send_msg.Int);
|
||
printf ("char: %c\n",send_msg.Char);
|
||
printf ("short: %hd\n",send_msg.Short);
|
||
printf ("long: %ld\n",send_msg.Long);
|
||
printf ("float: %d\n",send_msg.Float);
|
||
printf ("double: %d\n",send_msg.Double);
|
||
printf ("String: %s\n",send_msg.String);
|
||
printf ("--------------- end ---------------\n");
|
||
|
||
}
|
||
|
||
}
|
||
|
||
void *sub_weather(void *args)
|
||
{
|
||
void* context = zmq_ctx_new();
|
||
assert(context != NULL);
|
||
|
||
void* subscriber = zmq_socket(context, ZMQ_SUB);
|
||
assert(subscriber != NULL);
|
||
|
||
int ret = zmq_connect(subscriber, "tcp://localhost:5556");
|
||
assert(ret == 0);
|
||
|
||
ret = zmq_setsockopt(subscriber, ZMQ_SUBSCRIBE, "", 0);
|
||
assert(ret == 0);
|
||
|
||
while(1)
|
||
{
|
||
printf("into while\n");
|
||
char szBuf[1024] = {0};
|
||
ret = zmq_recv(subscriber, szBuf, sizeof(szBuf) - 1, 0);
|
||
if (ret > 0)
|
||
{
|
||
printf("%s\n", szBuf);
|
||
}
|
||
}
|
||
|
||
zmq_close(subscriber);
|
||
zmq_ctx_destroy(context);
|
||
}
|
||
|
||
int main (void)
|
||
{
|
||
int value_ret, sub_weather_ret;
|
||
pthread_t value_pth, sub_weather_pth; //线程ID变量
|
||
// 参数：创建的线程ID，线程参数，调用函数，函数参数
|
||
value_ret = pthread_create(&value_pth,NULL,value_server,NULL);
|
||
sub_weather_ret = pthread_create(&sub_weather_pth,NULL,sub_weather,NULL);
|
||
|
||
pthread_join(value_pth,NULL); // 等待线程结束
|
||
//pthread_join(sub_weather_pth.NULL);
|
||
|
||
return 0;
|
||
}
|