Unix域套接字
最后更新于：2022-04-02 04:06:32
[TOC]
## Unix域套接字
- 套接字( socket原是网络通信中使用的术语
- Unⅸx系统提供的域套接字提供了网络套接字类似的功能
## 流程
**服务端**
1. 创建套接字
2. 绑定(bind)套接字
3. 监听( isten)套接字
4. 接收&处理信息
**客户端**
1. 创建套接字
2. 连接套接字
3. 发送信息
## 示例
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define SOCKET_PATH "./domainsokcet"
#define MSG_SIZE 2048
int main()
{
int socket_fd, accept_fd;
int ret = 0;
socklen_t addr_len;
char msg[MSG_SIZE];
struct sockaddr_un server_addr;
// 1.创建套接字
socket_fd = socket(PF_UNIX, SOCK_STREAM, 0);
if (-1 == socket_fd)
{
std::cout << "Socket create failed!" << std::endl;
return -1;
}
// 移除已有套接字路径
remove(SOCKET_PATH);
//内存区域置零
bzero(&server_addr, sizeof(server_addr));
server_addr.sun_family = PF_UNIX;
strcpy(server_addr.sun_path, SOCKET_PATH);
// 2. 绑定域套接字
std::cout << "Binding socket... " << std::endl;
ret = bind(socket_fd, (sockaddr *)&server_addr, sizeof(server_addr));
if (0 > ret)
{
std::cout << "Binding failed! " << std::endl;
return -1;
}
// 3. 监听套接字
std::cout << "Listening socket... " << std::endl;
ret = listen(socket_fd, 10);
if (-1 == ret)
{
std::cout << "Listening failed... " << std::endl;
return -1;
}
std::cout << "Waiting for new requests... " << std::endl;
accept_fd = accept(socket_fd, NULL, NULL);
bzero(msg, MSG_SIZE);
// 4. 接收&处理信息
while (true)
{
recv(accept_fd, msg, MSG_SIZE, 0);
std::cout << "Received message from remote:" << msg << std::endl;
sleep(1);
}
close(accept_fd);
close(socket_fd);
return 0;
}
```
#include
#include
#include
#include
#include
#include
#include
#include
#include
//
#define SOCKET_PATH "./domainsokcet"
#define MSG_SIZE 2048
int main()
{
int socket_fd;
int ret = 0;
char msg[MSG_SIZE];
struct sockaddr_un server_addr;
// 1.创建套接字
socket_fd = socket(PF_UNIX, SOCK_STREAM, 0);
if (-1 == socket_fd)
{
std::cout << "Socket create failed!" << std::endl;
return -1;
}
//内存区域置零
bzero(&server_addr, sizeof(server_addr));
server_addr.sun_family = PF_UNIX;
strcpy(server_addr.sun_path, SOCKET_PATH);
// 2. 链接套接字
ret = connect(socket_fd,(sockaddr*)&(server_addr),sizeof(server_addr));
if(-1 ==ret){
std::cout << "Connect socket failed!" << std::endl;
return -1;
}
while (true)
{
std::cout << "Input message >>>" ;
fgets(msg,MSG_SEND,stdin);
ret = send(socket_fd,msg,MSG_SIZE,0);
}
close(socket_fd);
return 0;
}
```
编译运行 ``` > g++ server.cpp -o server && g++ client.cpp -o client > ./client Input message >>>ww Input message >>>aaa ``` ``` > ./server Binding socket... Listening socket... Waiting for new requests... Received message from remote:ww Received message from remote:aaa ```
';
server.cpp
``` #includeclient.php
``` #include编译运行 ``` > g++ server.cpp -o server && g++ client.cpp -o client > ./client Input message >>>ww Input message >>>aaa ``` ``` > ./server Binding socket... Listening socket... Waiting for new requests... Received message from remote:ww Received message from remote:aaa ```