c语言订阅系统,c语言事件订阅机制

本文目录一览：

• 1、杂志订阅管理的c语言
• 2、关于c语言动态指针相关问题？
• 3、关于mosquitto怎么用c语言实现消息的订阅和发送（mqtt）
• 4、C语言课程设计题目:杂志订阅管理软件

杂志订阅管理的c语言

#includestdio.h

#include “string.h”

#include “stdlib.h”

#include “conio.h”

#define max 20

struct magazine

{

char name[11];

char sex[6];

char addr[11];

char phone_number[12];

char unit_price[5];

char amount[4];

char time_limit[11];

}

order[max];void save(int n);

int load_record();

void search();

void printf_n(int n);

void printf_one(int i);

void input(int i);

void statistic();

void add();

void menu();void main()

{

FILE *fp;

fp=fopen(“record.txt”,”w”);/*在C:\Documents and Settings\Administrator里建立一个”record.txt”记事本*/

fclose(fp);

menu();

}void menu()

{

// void clrscr();

int w,n;

do

{

//clrscr();

printf(“\n”);

printf(“\t\t* * * * * * * * * * * * * * * * * * * * * * * * *\n”);

printf(“\t\t \n”);

printf(“\t\t \n”);

printf(“\t\t 欢迎来到杂志订阅系统! \n”);

printf(“\t\t \n”);

printf(“\t\t \n”);

printf(“\t\t* * * * * * * * * * * * * * * * * * * * * * * * *\n”);

printf(“\n\n\t\t *********************************************\n\n”);

printf(“\t\t 1:add_new_subscriber\n”);

printf(“\t\t 2:browse\n”);

printf(“\t\t 3:statistic\n”);

printf(“\t\t 4:exit\n\n”);

printf(“\t\t *********************************************\n\n”);

printf(” Choice your number(1-4):[ ]\b\b”);

scanf(“%d”,n);

if(n1||n4) w=1;

else w=0;

}

while (w==1);

/***************选择功能****************/

switch(n)

{

case 1:add();break; /*增加新订户记录*/

case 2:search();break; /*查找过期的订户记录并删除*/

case 3:statistic();break; /*统计*/

case 4:break; /*退出*/

}

}

/*********************添加模块************************/

void add()

{

int t,i,m;

system(“cls”);

t=load_record();

printf(“您需要添加多少用户的信息?\n”);

printf(“输入号码:[ ]\b\b\b”);

scanf(“%d”,m);

for(i=0;im;i++)

{

printf(“\n输入 %dth subscriber record.\n”,i+1);

input(t+i); /*调用输入函数*/

}

save(t+m); /*调用保存函数 保存t+m组数据*/

system(“cls”) ; /*******清屏*********/

menu(); /*返回登陆界面*/

}

void input(int i)

{

printf(“请输入:\n姓名 性别 地址 电话 杂志单价 数量 订阅期限\n”);

scanf(“%s%s%s%s%s%s%s”,order[i].name,order[i].sex,order[i].addr,order[i].phone_number,order[i].unit_price,order[i].amount,order[i].time_limit);

}

/**************************统计模块****************************/

void statistic()

{

int t;

t=load_record();

printf(“订阅者的数量[%d]\b\b\b”,t);

printf_n(t);

printf(“\n\n\n按任意键返回…\n\n”);

getch();

menu();

}void printf_one(int i) /*显示一个仪器记录的函数*/

{

printf(“%-10s %-5s %-10s %-11s %-4s %-3s %-10s\n\n”,order[i].name,order[i].sex,order[i].addr,order[i].phone_number,order[i].unit_price,order[i].amount,order[i].time_limit);

}void printf_n(int n) /*显示n个仪器记录的函数*/

{

int j;

system(“cls”); /**********清屏************/

printf(“姓名 性别 地址 电话号码 价格 数量 时间期限\n\n”);

for(j=0;jn;j++)

{

if((j+1)%10==0) /*控制显示，每屏显示10行*/

{

printf(“\n\n按任意键继续 …”);

getch();

puts(“\n\n”);

}

printf_one(j); /*调用显示一个仪器记录的函数*/

}

}

/***************查询模块****************/

void search()

{

FILE *fp;

char date[11],str[2];

int t,i,sum=0;

t=load_record();

system(“cls”);

printf(“请输入日期:[ ]\b\b\b\b\b\b\b\b\b\b\b”);

scanf(“%s”,date);

printf(“\n”);

if((fp=fopen(“record.txt”,”w”))==NULL)/*以只写方式打开*/

{

printf(“\n无法打开文件\n”);

exit(0);

}

system(“cls”);

printf(“\n”);

for(i=0;it;i++)

{

if(strcmp(order[i].time_limit,date)0)

{

sum++;

printf(“\n”);

printf_one(i); /**********把符合条件的记录显示出来*********/

printf(“\n\n记录已过期!”);

printf(“\n\n你想要删除此条信息吗?(‘Y’or’N’):[ ]\b\b”);

scanf(“%s”,str);;

if(strcmp(str,”Y”)==0||strcmp(str,”y”)==0)

continue;

}

fwrite(order[i],sizeof(struct magazine),1,fp);

}

fclose(fp);

if(sum==0)

{

printf(“***************************************************\n\n”);

printf(“很遗憾! 无法找到您想要的条件\n\n”);

printf(“***************************************************\n\n”);

}

printf(“\n\n\n按任意键返回前一步…\n”);

getch();

menu();

}/****************************公共函数************************************/

int load_record()/***加载仪器信息并计算记录仪器个数的函数***/

{

FILE *fp;

int i;

if((fp=fopen(“record.txt”,”r”))==NULL)/*以只读方式打开*/

{

printf(“\n无法打开文件\n”);

exit(0);

}

for(i=0;!feof(fp);i++)/*从文件中读入数据并保存在结构体数组中*/

fread(order[i],sizeof(struct magazine),1,fp);

fclose(fp);

return(i-1);

}void save(int n)/*n表示保存n组数据，m表示保存在哪个文件夹里*/

{

FILE *fp;

int i;

fp=fopen(“record.txt”,”w”);/*以只写方式打开*/

if(fp==NULL)

{

printf(“\n无法打开文件\n”);

exit(0);

}

for(i=0;in;i++)

{

fwrite(order[i],sizeof(struct magazine),1,fp);

}

fclose(fp);

}

关于c语言动态指针相关问题？

N应该是一个宏定义的常量

#define N 111//将这一句写在结构体的前面；

N就代表111了，当然也可以是其他数；

关于mosquitto怎么用c语言实现消息的订阅和发送（mqtt）

1.目标：测试Mosquitto使用MQTT协议发消息的相关性能指标，包含发送速度，并发负载能力，资源占用，消息到达率。

2.MQTT协议简介：

1).建立长连接。客户端发起请求和服务端建立长连接，建立成功后，服务端会返回ACK(CONNACK)

2).客户端订阅：客户端发起订阅，订阅成功后，服务端会返回ACK(SUBACK)

3).发消息：发布者会给服务端发消息，服务端在把消息给合适的客户端。

Qos=0(服务质量)：客户端消息收到后，不会发出ACK给服务端(PUBACK)。

　Qos =1:服务端会发ACK给发布者，客户端收到消息后会发ACK给服务端。

4).取消订阅：客户端发起取消订阅，服务端返回ACK(UNSUBACK)

5)PingreqPingresp:客户端和服务端会保持心跳。

3.存在问题：

1. 如何模拟出40W的用户

2. 如何长连接，订阅，发消息，取消订阅，Pingreq行为如何实现。

4. python开源库 Mosquitto.py，解决所有问题

1. 模拟40W用户

a)可以使用虚拟机和Mosquitto.py实现，具体为：一般一台虚拟机最多是6W+的模拟数据（需要修改句柄数，我使用5W），方法是Client_id可以简单的做出5W个来，然后调用Mosquitto里面的connect方法，建立长连接。准备8台虚拟机就可以实现40W客户端的模拟

2.行为的模拟

a)订阅：Mosquitto.subscribe / 发消息：Mosquitto.publish / 取消订阅：Mosquitto.unsubscribe。 简单一句话 Mosquitto库实现所有的行为.

5. 指标：发送速度，到达率，并发负载，资源占用。

a. 发送速度：服务端日志记录，分析解决

b. 到达率： 1.客户端记录下收到消息，分析计算。2.计算服务端收到的PUBACK（客户端收到消息返回的ACK），进行计算

c. 并发负载：5W 用户不断增加，注意观察服务端的负载情况。

e.资源占用：其实主要是cpu/mem/带宽：cpu多核的话需要观察top命令下的_id字段, mem可以观察free -h命令的剩余mem, 带宽可以使用mpstat进行观察

6. 可以遇见问题：

a. 模拟客户端的虚拟机需要修改句柄数才能支持5W的客户端模拟数量

b. 要先吃透MQTT协议的流程，吃透了进行测试会非常的方便

c. Clear session，设置为true则不为客户端保留休息，设置为false保留消息。其实就是客户端离线后在连接上可以收到之前推出的消息。

C语言课程设计题目:杂志订阅管理软件

你呀,干点正事吧,整天到晚的啊,你整天到晚的混得一点正型也没有,你看看人家,开车的买大楼房,你看看你,你一无所有,你脚下的地在抖,你身边的水在流。