服务器和陪消返客户芦饥端连接过程如下:
客户端:
socket-->connect-->read/write
服务器:
socket-->bind-->listen-->accept-->write/read
若要通讯必须要有服务器,只有在connect和accept建立好连接之后才能桥源真正的通信。
如果你是问编程的流程或者上述函数的意义和用法百度上一大堆。
共享内存的函数有以下几个:(1)int shmget(key_t key, int size, int shmflg),开辟或使用一块共享内存。
(2)void *shmat(int shmid, const void *shmaddr, int shmflg), 将参数shmid所指向的共享内存与当前进程连接。
当使用某共享内存时,需要先使用shmat,达成连接。
(3)int shmdt(const void *shmaddr),将先前用shmat连接的共享内存与当前进程解除连接。参数shmaddr为shmat返回的共享内存的地址。
在完成对共享内存的使用后,需要使用shmdt解除连接。
(4)int shmctl(int shmid, int cmd, struct shmid_ds *buf),控制内存的 *** 作。当cmd为IPC_RMID时,删除shmid所指的共享迹局内存。
这些函数的表头文件为<sys/ipc.h>和<sys/shm.h>
下面给出一个使用共享内存实现进程源州轿间通信的例雹肆子:进程A开辟一块新的共享内存,进程B修改这个共享内存,进程C打印输出这个共享内存的内容,进程D删除这个共享内存。
进程BCD运行的命令格式为:命令 共享内存ID,如./output 123432。
进程A代码如下:
int main()
{
int shmid
shmid = shmget(IPC_PRIVATE, SIZE, IPC_CREAT | 0600)
if (shmid <0)
{
perror("shmget error")
exit(1)
}
printf("create shared memory OK. shmid=%d/n", shmid)
return 0
}
进程B代码如下:
int main(int argc, char *argv[])
{
int shmid
char *shmaddr
if (argc != 2)
{
perror("argc error/n")
exit(1)
}
shmid = atoi(argv[1])
shmaddr = (char *)shmat(shmid, NULL, 0)
if ((int )shmaddr == -1)
{
perror("shmat error./n")
exit(1)
}
strcpy(shmaddr, "hello, world!")
shmdt(shmaddr)
return 0
}
进程C代码如下:
int main(int argc, char *argv[])
{
int shmid
char *shmaddr
if (argc != 2)
{
printf("argc error/n")
exit(1)
}
shmid = atoi(argv[1])
shmaddr = (char *)shmat(shmid, NULL, 0)
if ((int )shmaddr == -1)
{
perror("shmat error./n")
exit(1)
}
printf("%s/n", shmaddr)
shmdt(shmaddr)
return 0
}
进程D代码如下:
int main(int argc, char *argv[])
{
int shmid
if (argc != 2)
{
perror("argc error/n")
exit(1)
}
shmid = atoi(argv[1])
shmctl(shmid, IPC_RMID, NULL)
return 0
}
#include <stdio.h>#include <stdlib.h>
#include <errno.h>
#include <string.h>
#define N 10
#define MAX 100
int child_read_pipe(int fd)
{
char buf[N]
int n = 0
while(1)
{
n = read(fd,buf,sizeof(buf))
buf[n] = '\贺者0'
printf("春拍汪Read %d bytes : %s.\n",n,buf)
if(strncmp(buf,"quit",4) == 0)
break
}
return 0
}
int father_write_pipe(int fd)
{
char buf[MAX] = {0}
while(1)
{
printf(">")
fgets(buf,sizeof(buf),stdin)
buf[strlen(buf)-1] = '\0'
write(fd,buf,strlen(buf))
usleep(500)
if(strncmp(buf,"quit",4) == 0)
break
}
return 0
}
int main()
{
int pid
int fd[2]
if(pipe(fd) <0)
{
perror("Fail to pipe")
exit(EXIT_FAILURE)
}
if((pid = fork()) <扒仔 0)
{
perror("Fail to fork")
exit(EXIT_FAILURE)
}else if(pid == 0){
close(fd[1])
child_read_pipe(fd[0])
}else{
close(fd[0])
father_write_pipe(fd[1])
}
exit(EXIT_SUCCESS)
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)