linux下基于Socket通信,写一个ipc订阅端的进程程序,接收来自发送端的数据
时间: 2024-03-06 08:47:43 浏览: 61
一个简单的基于SOCKET类的收发程序
在Linux下,基于Socket通信也可以实现IPC订阅端的进程程序。下面是一个简单的示例代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#define PORT 12345
#define MAXLINE 1024
int main(int argc, char *argv[]) {
int sockfd;
struct sockaddr_in servaddr, cliaddr;
char buf[MAXLINE];
socklen_t len = sizeof(cliaddr);
// 创建socket
if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {
perror("socket error");
exit(1);
}
// 绑定地址和端口
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(PORT);
if (bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1) {
perror("bind error");
exit(1);
}
// 接收消息
while (1) {
if (recvfrom(sockfd, buf, MAXLINE, 0, (struct sockaddr *)&cliaddr, &len) == -1) {
perror("recvfrom error");
exit(1);
}
printf("Received message: %s\n", buf);
}
close(sockfd);
return 0;
}
```
在上面的代码中,我们使用socket函数创建一个UDP socket,并使用bind函数将其绑定到指定的地址和端口上。接着,我们使用recvfrom函数不断地接收来自发送端的消息,直到程序被手动终止。
需要注意的是,这里我们使用了一个名为buf的字符数组来存储消息内容。由于UDP是无连接的,所以我们需要在recvfrom函数中指定对端的地址和端口,这里我们使用了一个名为cliaddr的sockaddr_in结构体来表示。
阅读全文