当前位置：首页 > article >正文

假期day1

article 2025/1/24 18:41:29

第一天：请使用消息队列实现2个终端之间互相聊天

singal1.c

 #include <stdio.h>
 #include <string.h>
 #include <unistd.h>
 #include <stdlib.h>
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <fcntl.h>
 #include <pthread.h>
 #include <semaphore.h>
 #include <wait.h>
 #include <signal.h>
 #include <sys/socket.h>
 #include <arpa/inet.h>
 #include <sys/socket.h>
 #include <sys/ipc.h>
 #include <sys/sem.h>
 #include <semaphore.h>
 #include <sys/msg.h>
 #include <sys/shm.h>
 #include <sys/un.h>
typedef struct sockaddr_in addr_in_t;
typedef struct sockaddr addr_t;
typedef struct sockaddr_un addr_un_t;

key_t key;
int id;
typedef struct msgbuf
{
	long channel;
	char buf[128];
}msg_t;


void msg_w()
{
	msg_t msg;
	msg.channel = 1;
	while(1)
	{
		memset(msg.buf,0,128);
		//printf("张三:");
		scanf("%s",msg.buf);
		while(getchar()!=10);
		msgsnd(id,&msg,strlen(msg.buf),0);
	}
}

void msg_r()
{
	msg_t msg = {0};
	while(1)
	{
		memset(msg.buf,0,128);
		msgrcv(id,&msg,128,2,0);
		printf("好友李四:%s\n",msg.buf);
	}

}

void* pthread_main(void* arg)
{
	msg_w();
}

void handler(int signum)
{
	if(SIGINT == signum)
	{
		msgctl(id,IPC_RMID,NULL);
		exit(0);
	}
}

int main(int argc, const char *argv[])
{
	key = ftok("./ipc",2);
	id = msgget(key,IPC_CREAT | 0666);

	pthread_t pthread_id;
	signal(SIGINT,handler);
	pthread_create(&pthread_id,0,pthread_main,NULL);
	pthread_detach(pthread_id);
	msg_r();

	return 0;
}

singal2.c

#include <stdio.h>
 #include <string.h>
 #include <unistd.h>
 #include <stdlib.h>
 #include <sys/types.h>
 #include <sys/stat.h>
 #include <fcntl.h>
 #include <pthread.h>
 #include <semaphore.h>
 #include <wait.h>
 #include <signal.h>
 #include <sys/socket.h>
 #include <arpa/inet.h>
 #include <sys/socket.h>
 #include <sys/ipc.h>
 #include <sys/sem.h>
 #include <semaphore.h>
 #include <sys/msg.h>
 #include <sys/shm.h>
 #include <sys/un.h>
typedef struct sockaddr_in addr_in_t;
typedef struct sockaddr addr_t;
typedef struct sockaddr_un addr_un_t;

key_t key;
int id;
typedef struct msgbuf
{
	long channel;
	char buf[128];
}msg_t;


void msg_w()
{
	msg_t msg;
	msg.channel = 2;
	while(1)
	{
		memset(msg.buf,0,128);
		//printf("李四:");
		scanf("%s",msg.buf);
		while(getchar()!=10);
		msgsnd(id,&msg,strlen(msg.buf),0);
	}
}

void msg_r()
{
	msg_t msg = {0};
	while(1)
	{
		memset(msg.buf,0,128);
		msgrcv(id,&msg,128,1,0);
		printf("好友张三:%s\n",msg.buf);
	}

}

void* pthread_main(void* arg)
{
	msg_r();
}

void handler(int signum)
{
	if(SIGINT == signum)
	{
		msgctl(id,IPC_RMID,NULL);
		exit(0);
	}
}

int main(int argc, const char *argv[])
{
	key = ftok("./ipc",2);
	id = msgget(key,IPC_CREAT | 0666);

	pthread_t pthread_id;
	signal(SIGINT,handler);
	pthread_create(&pthread_id,0,pthread_main,NULL);
	pthread_detach(pthread_id);
	msg_w();

	return 0;
}