一.低级通信--信号通信
signal.c
#include <signal.h>
#include <stdio.h>
#include <unistd.h>
/*捕捉到信号sig之后，执行预先预定的动作函数*/
void sig_alarm(int sig)
{
printf("---the signal received is %d. /n", sig)
signal(SIGINT, SIG_DFL)//SIGINT终端中断信号，SIG_DFL：恢复默认行为，SIN_IGN：忽略信号
}
int main()
{
signal(SIGINT, sig_alarm)//捕捉终端中断信号
while(1)
{
printf("waiting here!/n")
sleep(1)
}
return 0
}
二.管道通信
pipe.c
#include <stdio.h>
#define BUFFER_SIZE 30
int main()
{
int x
int fd[2]
char buf[BUFFER_SIZE]
char s[BUFFER_SIZE]
pipe(fd)//创建管道
while((x=fork())==-1)//创建管道失败时，进入循环
/*进入子进程，子进程向管道中写入一个字符串*/
if(x==0)
{
sprintf(buf,"This is an example of pipe!/n")
write(fd[1],buf,BUFFER_SIZE)
exit(0)
}
/*进入父进程，父进程从管道的另一端读出刚才写入的字符串*/
else
{
wait(0)//等待子进程结束
read(fd[0],s,BUFFER_SIZE)//读出字符串，并将其储存在char s[]中
printf("%s",s)//打印字符串
}
return 0
}
三.进程间通信——IPC
①信号量通信
sem.c
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
/*联合体变量*/
union semun
{
int val//信号量初始值
struct semid_ds *buf
unsigned short int *array
struct seminfo *__buf
}
/*函数声明，信号量定义*/
static int set_semvalue(void)//设置信号量
static void del_semvalue(void)//删除信号量
static int semaphore_p(void) //执行P *** 作
static int semaphore_v(void) //执行V *** 作
static int sem_id//信号量标识符
int main(int argc, char *argv[])
{
int i
int pause_time
char op_char = 'O'
srand((unsigned int)getpid())
sem_id = semget((key_t)1234, 1, 0666 | IPC_CREAT)//创建一个信号量,IPC_CREAT表示创建一个新的信号量
/*如果有参数，设置信号量，修改字符*/
if (argc >1)
{
if (!set_semvalue())
{
fprintf(stderr, "Failed to initialize semaphore/n")
exit(EXIT_FAILURE)
}
op_char = 'X'
sleep(5)
}
for(i = 0i <10i++)
{
/*执行P *** 作*/
if (!semaphore_p())
exit(EXIT_FAILURE)
printf("%c", op_char)
fflush(stdout)
pause_time = rand() % 3
sleep(pause_time)
printf("%c", op_char)
fflush(stdout)
/*执行V *** 作*/
if (!semaphore_v())
exit(EXIT_FAILURE)
pause_time = rand() % 2
sleep(pause_time)
}
printf("/n%d - finished/n", getpid())
if (argc >1)
{
sleep(10)
del_semvalue()//删除信号量
}
exit(EXIT_SUCCESS)
}
/*设置信号量*/
static int set_semvalue(void)
{
union semun sem_union
sem_union.val = 1
if (semctl(sem_id, 0, SETVAL, sem_union) == -1)
return(0)
return(1)
}
/*删除信号量*/
static void del_semvalue(void)
{
union semun sem_union
if (semctl(sem_id, 0, IPC_RMID, sem_union) == -1)
fprintf(stderr, "Failed to delete semaphore/n")
}
/*执行P *** 作*/
static int semaphore_p(void)
{
struct sembuf sem_b
sem_b.sem_num = 0
sem_b.sem_op = -1/* P() */
sem_b.sem_flg = SEM_UNDO
if (semop(sem_id, &sem_b, 1) == -1)
{
fprintf(stderr, "semaphore_p failed/n")
return(0)
}
return(1)
}
/*执行V *** 作*/
static int semaphore_v(void)
{
struct sembuf sem_b
sem_b.sem_num = 0
sem_b.sem_op = 1/* V() */
sem_b.sem_flg = SEM_UNDO
if (semop(sem_id, &sem_b, 1) == -1)
{
fprintf(stderr, "semaphore_v failed/n")
return(0)
}
return(1)
}
②消息队列通信
send.c
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#define MAX_TEXT 512
/*用于消息收发的结构体--my_msg_type：消息类型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type
char some_text[MAX_TEXT]
}
int main()
{
int running = 1//程序运行标识符
struct my_msg_st some_data
int msgid//消息队列标识符
char buffer[BUFSIZ]
/*创建与接受者相同的消息队列*/
msgid = msgget((key_t)1234, 0666 | IPC_CREAT)
if (msgid == -1)
{
fprintf(stderr, "msgget failed with error: %d/n", errno)
exit(EXIT_FAILURE)
}
/*向消息队列中发送消息*/
while(running)
{
printf("Enter some text: ")
fgets(buffer, BUFSIZ, stdin)
some_data.my_msg_type = 1
strcpy(some_data.some_text, buffer)
if (msgsnd(msgid, (void *)&some_data, MAX_TEXT, 0) == -1)
{
fprintf(stderr, "msgsnd failed/n")
exit(EXIT_FAILURE)
}
if (strncmp(buffer, "end", 3) == 0)
{
running = 0
}
}
exit(EXIT_SUCCESS)
}
receive.c
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <errno.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
/*用于消息收发的结构体--my_msg_type：消息类型，some_text：消息正文*/
struct my_msg_st
{
long int my_msg_type
char some_text[BUFSIZ]
}
int main()
{
int running = 1//程序运行标识符
int msgid//消息队列标识符
struct my_msg_st some_data
long int msg_to_receive = 0//接收消息的类型--0表示msgid队列上的第一个消息
/*创建消息队列*/
msgid = msgget((key_t)1234, 0666 | IPC_CREAT)
if (msgid == -1)
{
fprintf(stderr, "msgget failed with error: %d/n", errno)
exit(EXIT_FAILURE)
}
/*接收消息*/
while(running)
{
if (msgrcv(msgid, (void *)&some_data, BUFSIZ,msg_to_receive, 0) == -1)
{
fprintf(stderr, "msgrcv failed with error: %d/n", errno)
exit(EXIT_FAILURE)
}
printf("You wrote: %s", some_data.some_text)
if (strncmp(some_data.some_text, "end", 3) == 0)
{
running = 0
}
}
/*删除消息队列*/
if (msgctl(msgid, IPC_RMID, 0) == -1)
{
fprintf(stderr, "msgctl(IPC_RMID) failed/n")
exit(EXIT_FAILURE)
}
exit(EXIT_SUCCESS)
}
③共享内存通信
share.h
#define TEXT_SZ 2048 //申请共享内存大小
struct shared_use_st
{
int written_by_you//written_by_you为1时表示有数据写入，为0时表示数据已经被消费者提走
char some_text[TEXT_SZ]
}
producer.c
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include "share.h"
int main()
{
int running = 1//程序运行标志位
void *shared_memory = (void *)0
struct shared_use_st *shared_stuff
char buffer[BUFSIZ]
int shmid//共享内存标识符
/*创建共享内存*/
shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT)
if (shmid == -1)
{
fprintf(stderr, "shmget failed/n")
exit(EXIT_FAILURE)
}
/*将共享内存连接到一个进程的地址空间中*/
shared_memory = shmat(shmid, (void *)0, 0)//指向共享内存第一个字节的指针
if (shared_memory == (void *)-1)
{
fprintf(stderr, "shmat failed/n")
exit(EXIT_FAILURE)
}
printf("Memory attached at %X/n", (int)shared_memory)
shared_stuff = (struct shared_use_st *)shared_memory
/*生产者写入数据*/
while(running)
{
while(shared_stuff->written_by_you == 1)
{
sleep(1)
printf("waiting for client.../n")
}
printf("Enter some text: ")
fgets(buffer, BUFSIZ, stdin)
strncpy(shared_stuff->some_text, buffer, TEXT_SZ)
shared_stuff->written_by_you = 1
if (strncmp(buffer, "end", 3) == 0)
{
running = 0
}
}
/*该函数用来将共享内存从当前进程中分离,仅使得当前进程不再能使用该共享内存*/
if (shmdt(shared_memory) == -1)
{
fprintf(stderr, "shmdt failed/n")
exit(EXIT_FAILURE)
}
printf("producer exit./n")
exit(EXIT_SUCCESS)
}
customer.c
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include "share.h"
int main()
{
int running = 1//程序运行标志位
void *shared_memory = (void *)0
struct shared_use_st *shared_stuff
int shmid//共享内存标识符
srand((unsigned int)getpid())
/*创建共享内存*/
shmid = shmget((key_t)1234, sizeof(struct shared_use_st), 0666 | IPC_CREAT)
if (shmid == -1)
{
fprintf(stderr, "shmget failed/n")
exit(EXIT_FAILURE)
}
/*将共享内存连接到一个进程的地址空间中*/
shared_memory = shmat(shmid, (void *)0, 0)//指向共享内存第一个字节的指针
if (shared_memory == (void *)-1)
{
fprintf(stderr, "shmat failed/n")
exit(EXIT_FAILURE)
}
printf("Memory attached at %X/n", (int)shared_memory)
shared_stuff = (struct shared_use_st *)shared_memory
shared_stuff->written_by_you = 0
/*消费者读取数据*/
while(running)
{
if (shared_stuff->written_by_you)
{
printf("You wrote: %s", shared_stuff->some_text)
sleep( rand() % 4 )
shared_stuff->written_by_you = 0
if (strncmp(shared_stuff->some_text, "end", 3) == 0)
{
running = 0
}
}
}
/*该函数用来将共享内存从当前进程中分离,仅使得当前进程不再能使用该共享内存*/
if (shmdt(shared_memory) == -1)
{
fprintf(stderr, "shmdt failed/n")
exit(EXIT_FAILURE)
}
/*将共享内存删除,所有进程均不能再访问该共享内存*/
if (shmctl(shmid, IPC_RMID, 0) == -1)
{
fprintf(stderr, "shmctl(IPC_RMID) failed/n")
exit(EXIT_FAILURE)
}
exit(EXIT_SUCCESS)
}
摘自：http://blog.csdn.net/piaojun_pj/article/details/5943736
方法/步骤1
1.服务器端的代码：
void
SocketServer::CreateConnect(){std::cout<<"start Create
Socket!"<<std::endl m_nSocket = -1 struct sockaddr_in
server_addr struct sockaddr_in client_addr int
portnumber=4321 if((m_nSocket=socket(AF_INET,SOCK_STREAM,0))==-1)
{std::cout<<"socket Create
Failed!"<<strerror(errno)<<std::endl return }
std::cout<<"Create Socket Finish!"<<std::endl/*
服务器端填充 sockaddr结构 */bzero(&server_addr,sizeof(struct
sockaddr_in)) server_addr.sin_family=AF_INET
server_addr.sin_addr.s_addr=inet_addr("127.0.0.1")
server_addr.sin_port=htons(portnumber) /* 捆绑sockfd描述符 */
if(bind(m_nSocket,(struct sockaddr *)(&server_addr),sizeof(struct
sockaddr))==-1){std::cout<<"Server Bind
Failed!"<<strerror(errno)<<std::endl return }
std::cout<<"bind Socket Finish!"<<std::endl /*
监听sockfd描述符 */if(listen(m_nSocket,5)==-1){
std::cout<<"Listen
Failed!"<<strerror(errno)<<std::endl return }
std::cout<<"listen Socket Finish!"<<std::endl
while(1){/* 服务器阻塞,直到客户程序建立连接 */
std::cout<<"listen start..."<<std::endl int
nNewFd=-1 size_t nSize = sizeof(struct sockaddr_in)
if((nNewFd=accept(m_nSocket,(struct sockaddr
*)(&client_addr),&(nSize))) == -1){
std::cout<<"accept
Failed!"<<strerror(errno)<<std::endl return
}std::cout<<"server Get Connect
from:"<<inet_ntoa(client_addr.sin_addr)<<std::endl
while(1){char buf[256] = "0" size_t
len = recv( nNewFd, buf, 256, 0)if ( len >0)
std::cout<<"接受的消息为："<<buf<<std::endl
else {if ( len <0)
std::cout<<"错误为："<<strerror( errno)<<std::endl
else
std::cout<<"客户端断开："<<std::endl break
}}/* 这个通讯已经结束 *///close(nNewFd)
/* 循环下一个 */}}
2
2.客户端代码：
//
创建链接void SocketClient::CreateConnect(){char buffer[1024] struct
sockaddr_in server_addr std::cout<<"socket create
start!"<<std::endl /* 客户程序开始建立 sockfd描述符 */
if((m_nSocket=socket(AF_INET,SOCK_STREAM,0))==-1){
std::cout<<"Client socket Create
Failed!!"<<strerror(errno)<<std::endl return }
std::cout<<"socket create finshed!"<<std::endl /*
客户程序填充服务端的资料 */int portnumber = 4321
bzero(&server_addr,sizeof(server_addr))
server_addr.sin_family=AF_INET
server_addr.sin_port=htons(portnumber)
server_addr.sin_addr.s_addr=inet_addr("127.0.0.1") /*
客户程序发起连接请求 */if(connect(m_nSocket,(struct sockaddr
*)(&server_addr),sizeof(struct sockaddr))==-1){
std::cout<<"Client connect
Fialed!"<<strerror(errno)<<std::endl return }
std::cout<<"connect finshed!"<<std::endl std::string
str="start..." while(!str.empty()){
std::cout<<"starting....!"<<std::endl
std::cin>>str size_t len = send ( m_nSocket, str.c_str(),
str.length(), 0)if ( len <0){
std::cout<<"消息发送失败"<<str<<strerror
(errno)<<std::endl }else{
std::cout<<"消息发送成功"<<str<<std::endl }}
close(m_nSocket)}
3
3.编译完成后，启动服务器端代码和客户端代码就可以进行通信了。
4
4.
普及一下TCP/IP协议的部分知识，大家都知道TCP是面向链接的协议，即在进行通信前服务器是被动链接，客户端是主动链接，那么客户端与服务器端的连
接需要经过三次握手才能建立链接。在整个通信过程中客户端与服务器端的进行的通信都有确认机制，保证包能顺利的到达对方，但这也不是100%，中间的路由
等中间桥出现问题，也有可能造成数据包的丢失，而任何一方没有收到确认包，都会一直处于等待和重传的过程中...
服务器：
创建socket->bind->listen->recv(send)->close
客户端：
创建socket->connect->recv(send)->close
兄弟看到你这么高的分我就找了些资料：也算是对昨天学的知识总结一下吧一、先说概念不管是windows还是linux下的进程和线程概念都是一样的，只是管理进程和线程的方式不一样，这个是前提，到时候你可别问我windows下进程和线程啊。这个涉及到 *** 作系统原理。下面给你解答。
说道进程不得不提作业这个名词 ，我想兄弟你电脑里不会有一个程序吧对不？当你的系统启动完毕后你看看你的任务管理器里是不是有很多进程呢？那么多程序是怎么调如内存呢？能理解吗？这里要明白程序和进程的关系，程序是你磁盘上的一个文件，当你需要它时进入内存后才成为进程，好比QQ在磁盘上就是一个文件而已，只有进入了内存才成为进程，进程是活动的。QQ要扫描你文件啊，记录你聊天记录啊，偷偷上传个啥东西什么的你也不知道对不，他是活动的。这个能明白吗？
再看作业，这个作业可不是你写作业的那个作业啊。系统一看好家伙你个QQ那么大的家伙你想一下子进入内存啊？没门！慢慢来嘛，系统就把QQ程序分为好几块，这几块不能乱分的，要符合自然结构就是循环啦选择啦这样的结构，你把人家循环结构咔嚓截断了，怎么让人家QQ运行啊？这就是作业要一块一块的进入内存，同时要为作业产生JCB（JOB CONTROL BLOCK)作业控制块，你进入内存不能乱跑啊，要听系统的话，你要是进入系统自己的内存。框一下，内存不能读写 对话框就出来了，严重点直接蓝脸给你！你懂得。这是window下的，linux下直接给你报错！没事了就！所一系统通过jcb控制进程。JCB包含了进程号优先级好多内容，你打开你的windows任务管理器看看进程是不是有好多属性啊？那就是PCB（PRCESS，CONTROL BLOCK）同理作业也包含那些内容只是多少而已。下面写出进程特点：
1、进程是分配计算机资源最小的单位。你想啊人是要用程序干活的吧？你把程序调入内存成了就成了进程，所以说进程是分配资源的最小单位。你在linux下打开终端输入top命令看是不是有好多进程？
2、进程有 *** 作系统为作业产生。有“父进程”产生“子进程”之间是父子关系，并可以继续向下产生“子进程”。还拿QQ来说，你双击QQ.exe。QQ启动了输入账号密码打开主界面了。这时候你要聊天，QQ进程赶紧产生个“儿子”说 “儿子你去陪主人聊天去吧。这样子进程产生了。突然你想看美女要传照片这时候那个”儿子“有”生“了一个”儿子“说”儿子“你去传照片。那个“儿子领到任务去传照片了。这时你想关了QQ，QQ提示你说”你还有个“儿子”和“孙子”还在干活呢你真要结束吗？你蒽了确定。QQ对他“儿子”（你聊天窗口）说：”儿子啊对不起了，主人要关闭我你也不能活啊“咔嚓一下”儿子“死了，儿子死之前对他儿子说：“儿子啊你爷爷不让我活了，你也别活了咔嚓孙子也死了。最后世界安静了。这就是进程的父子关系。能明白吗？记住：进程之活动在内存中。不能使用CPU，只管分配资源。
再说线程：线程也产生在内存中并且在内存中存在相当长的时间，但它的活动区域主要在CPU中，并且运行和灭亡都存在于CPU中，可以这么说，线程是程序中能被系统调度进入CPU中最小程序单位，它能直接使用进程分配的CPU的资源。
还拿QQ来说当你要传文件时QQ总要判断一下文件的扩展名吧，ok这时那个”儿子“赶紧对它爸爸说我需要一个线程判断扩展名QQ赶紧对一个管这个的线程说：”快点去CPU里计算下那个扩展名是什么然后向主人报告计算完了就“死了”消亡了，但是它的线程还在内存中！还等着你下一次传文件然后计算然后消亡！
线程之间是相互独立的。一个在CPU，一个在内存里还能有关系吗对不？CPU在每一个瞬间只能进入一个线程，当线程进入CPU时立即产生一个新的线程，新线程仍停留在内存中，就好比上面那个传文件还会等着你再传文件再计算扩展名。
线程相对线程是独立的，但它在内存中并不是独立的，这就好比你不开QQ能用QQ传输文件吗？它只存在与进程分配的资源中，也就是说计算扩展名这个线程只能停留在QQ这个进程中，不能跑到别的进程里！！相当于程序产生了新的进程和线程，进程向CPU申请资源，再有线程来使用，他们都是为程序服务的只是分工不同！
因为你没提问linux下是怎么管理进程和线程的所以我就不回答了，这个问题我建议你还是看看《笨兔兔的故事》里面讲到了linux是怎么管理进程和线程的。挺幽默的比我说得还好。
你第二个问题说实话我回答不了你！我想你现在连进程和线程还没理解第二个你更理解不了了你说对不？我猜的其实你用C/C++不管是在windows下编程还是在Linux下编程思想都是一样的对吧，如果你理解了在windows下线程间通信，在linux更没问题了！
参考资料：黑客手册2009合订本非安全第一二季244页，245页，328页，329页，398页，399页
浅谈 *** 作系统原理 （一 二三）
ubuntu中文论坛 笨兔兔的故事
http://forum.ubuntu.org.cn/viewtopic.php?f=120&t=267518
希望我的回答你能理解
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）