UNIX进程之间的通信( 三 ) _云知道

perror("msgget");
exit(1);
}
printf("msgqueue_id=%dn",msgqueue_id);
}

switch(tolower(argv[1][0]))
{
case "s": send_message(atoi(argv[4]), (struct mymsgbuf *)&qbuf,
atol(argv[2]), argv[3]);
break;
case "r": read_message(msgqueue_id, &qbuf, atol(argv[2]));
break;
case "d": remove_queue(atoi(argv[2]));
remove_queue(msgqueue_id);
break;
case "m": change_queue_mode(msgqueue_id, argv[2]);
break;

default: usage();

}

return(0);
}

void send_message(int qid, struct mymsgbuf *qbuf, long type, char *text)
{
printf("msgqueue_id=%dn",qid);
/* Send a message to the queue */
printf("Sending a message ...n");
qbuf->mtype = type;
strcpy(qbuf->mtext, text);
printf(" Type: %ld Text: %sn", qbuf->mtype, qbuf->mtext);

if((msgsnd(qid, (struct msgbuf *)qbuf,
strlen(qbuf->mtext) 1, 0)) ==-1)
{
perror("msgsnd");
exit(1);
}
}

void read_message(int qid, struct mymsgbuf *qbuf, long type)
{
/* Read a message from the queue */
printf("Reading a message ...n");
qbuf->mtype = type;
msgrcv(qid, (struct msgbuf *)qbuf, MAX_SEND_SIZE, type, 0);

printf(" Type: %ld Text: %sn", qbuf->mtype, qbuf->mtext);
}

void remove_queue(int qid)
{
/* Remove the queue */
msgctl(qid, IPC_RMID, 0);
}

void change_queue_mode(int qid, char *mode)
{
struct msqid_ds myqueue_ds;

/* Get current info */
msgctl(qid, IPC_STAT, &myqueue_ds);

/* Convert and load the mode */
sscanf(mode, "%ho", &myqueue_ds.msg_perm.mode);

/* Update the mode */
msgctl(qid, IPC_SET, &myqueue_ds);
}

void usage(void)
{
fprintf(stderr, "msgtool - A utility for tinkering with msg queuesn");
fprintf(stderr, "nUSAGE: msgtool (s)end n");
fprintf(stderr, " (r)ecv n");
fprintf(stderr, " (d)eleten");
fprintf(stderr, " (m)ode n");
fprintf(stderr, "note: type must be number!n");
exit(1);
}

2，Tcp/IP socket编程例子

1), ClIEnt方

#include
#include
#include
#include
#include
#include

int main(int argc, char *argv[])
{
int sockfd ,newsockfd, help, sent;
struct sockaddr_in peer;
struct hostent *serverhost;
char buff[5000];

if(argc<2) {
fprintf(stderr, "Usage: coc n");
exit(1);
}

if ((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0 ) {
perror("socket");
exit(1);
}

if((serverhost = gethostbyname(argv[1])) == 0) {
perror("gethostbyname");
exit(1);
}

peer.sin_family = AF_INET;
peer.sin_port = htons(10000);
peer.sin_addr = *(struct in_addr*)serverhost->h_addr_list[0];

if (connect(sockfd, &peer, sizeof(peer)) < 0 ) {
perror("connect");
exit(1);
}

for(help=0; helpbuff[help] = "0" help;

write(sockfd, buff, 5000);

close(sockfd);
}

2, Server方

#include
#include
#include
#include

void process(int fd)
{
char buff[10000];
int received;
int help,read_bytes;

received = 5000;
memset ( buff, ".", received );
read_bytes = read(fd, buff, received);
if (read_bytes < 0) {
perror("read");
exit(1);
}

printf("%d bytes have received on socket %dn", read_bytes, fd);
printf("buff=n%sn", buff);
for(help=0; helpif(buff[help] != "0" help)
{
printf("Error on position %dn", help);
break;
}
}

int main(void)
{
int sockfd ,newsockfd;
struct sockaddr_in myaddr, peer;

int addrlen1,addrlen2;

if ((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0 ) {
perror("socket");
exit(1);
}

addrlen1 = sizeof(myaddr);

myaddr.sin_family = AF_INET;
myaddr.sin_port = htons(10000);
myaddr.sin_addr.s_addr = INADDR_ANY;
if (bind(sockfd, &myaddr , addrlen1) < 0 ) {
perror("bind");
exit(1);
}

UNIX进程之间的通信( 三 )

推荐阅读

朕也不想这样动漫插曲是什么

发生掉骨朵该怎么办灯笼花的繁殖方法有哪些

蚊香灰可以做花肥吗

小米11发布会完整版！感受领先科技的狂潮！

世界前十美术学院世界十大美术学院

怎样让孩子坚强勇敢怎样培养孩子勇敢坚强

远离系统Ping漏洞的威胁

清明节的发源地

如何让自己的手机号码变成空号的

瘦腰两侧的肉方法如何瘦腰两侧的肉

杨烁代言什么车

求有关林徽因的所有书

女人四十为什么怀孕难

海绵里的头发怎么弄出来

威尼斯有哪些著名景点

青铜技术起源于哪里