linux下socket本地套接字通讯

server/2024/12/15 17:23:34/

        使用套接字除了可以实现网络间不同主机间的通信外,还可以实现同一主机的不同进程间的通信,且建立的通信是双向的通信。socket进程通信与网络通信使用的是统一套接口,只是地址结构与某些参数不同。        

用途

  1. 进程间通信:本地套接字允许在同一台主机上的不同进程之间进行数据传输,类似于管道(pipe)和命名管道(FIFO),但提供了更灵活和通用的解决方案。
  2. 资源共享:通过本地套接字,进程可以共享数据、文件或设备等资源,实现进程间的协同工作。
  3. 服务间交互:在分布式系统或微服务架构中,本地套接字可以用于服务间的本地通信,提高服务间的交互效率和可靠性。

应用场景

  1. 数据库服务:数据库服务器和客户端进程通常运行在同一台主机上,通过本地套接字进行通信,实现数据的查询、插入、更新和删除等操作。
  2. 中间件服务:在分布式系统中,中间件服务(如消息队列、缓存服务等)通常与应用程序运行在同一台主机上,通过本地套接字进行通信,实现数据的传递和处理。
  3. 调试和测试:在软件开发过程中,开发人员可以使用本地套接字在本地环境中模拟网络通信,进行调试和测试工作,提高开发效率和质量。
  4. 本地进程监控和管理:系统管理工具可以使用本地套接字监控和管理本地进程,如获取进程状态、终止进程等。

优点

  1. 高效性:由于本地套接字不涉及网络通信,因此数据传输速度更快,延迟更低。
  2. 可靠性:本地套接字提供了稳定的进程间通信机制,避免了网络通信中的不确定性和延迟。
  3. 安全性:由于数据在本地主机上传输,因此安全性更高,不易受到网络攻击和窃听。

本地套接字与普通套接字开发上的主要差异

  1. 协议族:本地套接字使用AF_UNIX,而普通套接字使用AF_INET(IPv4)或AF_INET6(IPv6)。

  2. 地址结构体:本地套接字使用struct sockaddr_un,而普通套接字使用struct sockaddr_in(IPv4)或struct sockaddr_in6(IPv6)。

  3. 套接字文件:本地套接字在文件系统中创建一个套接字文件(如/tmp/unix_socket),而普通套接字则使用IP地址和端口号进行通信。

  4. 通信范围:本地套接字仅限于同一台计算机上的进程间通信,而普通套接字可以在网络上的不同计算机之间进行通信。

  5. 性能:本地套接字由于不经过网络协议栈,通常具有更低的延迟和更高的吞吐量。

  6. 安全性:本地套接字由于通信双方在同一台计算机上,相对更安全,但也需要注意文件系统的权限设置。普通套接字则可能面临网络攻击的风险,需要采取适当的安全措施。

 

完整例子如下:不解释了。

service:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>#define SOCKET_PATH "/tmp/unix_socket"
#define BUFFER_SIZE 1024int main() {int server_fd, new_socket;struct sockaddr_un address;int addrlen = sizeof(address);char buffer[BUFFER_SIZE] = {0};int opt = 1;int addrlen_size;// 创建套接字if ((server_fd = socket(AF_UNIX, SOCK_STREAM, 0)) == 0) {perror("socket failed");exit(EXIT_FAILURE);}// 设置套接字选项,允许重用地址和端口if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {perror("setsockopt");close(server_fd);exit(EXIT_FAILURE);}// 清除地址结构memset(&address, 0, sizeof(struct sockaddr_un));// 设置地址和端口address.sun_family = AF_UNIX;strncpy(address.sun_path, SOCKET_PATH, sizeof(address.sun_path) - 1);// 绑定套接字到地址if (bind(server_fd, (struct sockaddr *)&address, sizeof(struct sockaddr_un)) < 0) {perror("bind failed");close(server_fd);exit(EXIT_FAILURE);}// 监听连接if (listen(server_fd, 3) < 0) {perror("listen");close(server_fd);unlink(SOCKET_PATH); // 删除套接字文件exit(EXIT_FAILURE);}// 接受客户端连接if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen_size)) < 0) {perror("accept");close(server_fd);unlink(SOCKET_PATH); // 删除套接字文件exit(EXIT_FAILURE);}// 读取客户端发送的数据int valread = read(new_socket, buffer, BUFFER_SIZE);printf("Received: %s\n", buffer);// 发送响应给客户端char *hello = "Hello from server";send(new_socket, hello, strlen(hello), 0);printf("Hello message sent\n");// 关闭套接字close(new_socket);close(server_fd);unlink(SOCKET_PATH); // 删除套接字文件return 0;
}

client:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/un.h>#define SOCKET_PATH "/tmp/unix_socket"
#define BUFFER_SIZE 1024int main() {int sock = 0;struct sockaddr_un serv_addr;char buffer[BUFFER_SIZE] = {0};char *hello = "Hello from client";// 创建套接字if ((sock = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {perror("Socket creation error");return -1;}serv_addr.sun_family = AF_UNIX;strcpy(serv_addr.sun_path, SOCKET_PATH);// 连接服务端if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(struct sockaddr_un)) < 0) {perror("Connection Failed");return -1;}// 发送数据到服务端send(sock, hello, strlen(hello), 0);printf("Hello message sent\n");// 读取服务端的响应int valread = read(sock, buffer, BUFFER_SIZE);printf("Received: %s\n", buffer);// 关闭套接字close(sock);return 0;
}

 其余自己脑补去。


http://www.ppmy.cn/server/150398.html

相关文章

Redis 附加功能(一) - 数据库

Redis的数据会被存储到一个名为数据库的容器中。一个Redis服务器可以包含多个数据库&#xff0c;默认情况下&#xff0c;会创建16个数据库。这些数据库用号码进行标志&#xff0c;第一个数据库为0号数据库。 数据库 切换到指定的数据库&#xff1a;SELECT index 获取所有与给定…

在Windows 10中使用SSH远程连接服务器(附花生壳操作方法)

SSH 在 linux 中是一种重要的系统组件&#xff0c;用户可以使用 SSH 来远程连接 linux 系统的计算机&#xff0c;或者传输文件。不过在 win10 以前&#xff0c;windows 并不原生支持 SSH&#xff0c;需要借助第三方工具来使用 SSH 功能。而实际上&#xff0c;微软在 2015 年就曾…

redis集群 服务器更换ip,怎么办,怎么更换redis集群的ip

redis集群 服务器更换ip&#xff0c;怎么办&#xff0c;怎么更换redis集群的ip 1、安装redis三主三从集群2、正常状态的redis集群3、更改redis集群服务器的ip 重启服务器 集群会down4、更改redis集群服务器的ip 重启服务器 集群down的原因5、更改redis集群服务器的ip后&#xf…

Python中定义抽象基类

What python中定义可以定义抽象类&#xff0c;和Java中的抽象类是一样的&#xff0c;不能被直接实例化&#xff0c;而是作为一个基类&#xff0c;主要用于定义一组接口规范&#xff0c;接口的实现在继承其的子类中完成&#xff0c;并且要求子类必须实现定义的所有接口&#xf…

es build 使用配置详解:快速、可扩展的 JavaScript 打包器

引言 es build 是一个快速、可扩展的 JavaScript 打包器和压缩器&#xff0c;它的目标是成为最快的打包器。它使用 Go 编写&#xff0c;可以在几乎瞬间内完成大多数项目的构建。在本文中&#xff0c;我们将深入了解 es build&#xff0c;并探讨其如何实现如此出色的性能。 什…

如何使用 Python 写入文本文件 ?

在Python编程中&#xff0c;写入文本文件是一项基本且重要的操作。 无论是生成日志文件、配置文件&#xff0c;还是进行数据输出&#xff0c;都需要用到这一技能。 下面&#xff0c;我将详细介绍如何使用Python写入文本文件&#xff0c;并提供一些实际开发中的建议和注意事项…

MySQL 记录锁+间隙锁防幻读方案

1. 什么是幻读&#xff1f; 定义&#xff1a; 幻读是指在事务过程中&#xff0c;一个事务执行了某些查询操作后&#xff0c;另一事务插入、删除或更新了满足查询条件的新数据&#xff0c;当第一个事务再次执行相同的查询操作时&#xff0c;结果集出现了“幻觉”&#…

docker tdengine windows快速体验

#拉取镜像 docker pull tdengine/tdengine:2.6.0.34#容器运行 docker run -d --name td2.6 --restartalways -p 6030:6030 -p 6041:6041 -p 6043:6043 -p 6044-6049:6044-6049 -p 6044-6045:6044-6045/udp -p 6060:6060 tdengine/tdengine:2.6.0.34#容器数据持久化到本地 #/va…