Redis源码分析之anet网络通信的封装

anet是redis对tcp/ip网络中socket api接口的一个全面的封装,针对server/client端。封装的api的接口如下,注释了主要的接口:

// tcp连接
int anetTcpConnect(char *err, char *addr, int port);
// 非阻塞连接
int anetTcpNonBlockConnect(char *err, char *addr, int port);
// 非阻塞绑定
int anetTcpNonBlockBindConnect(char *err, char *addr, int port, char *source_addr);
// 非阻塞绑定
int anetTcpNonBlockBestEffortBindConnect(char *err, char *addr, int port, char *source_addr);
//unix socket connect
int anetUnixConnect(char *err, char *path);
// unix non-block connect 
int anetUnixNonBlockConnect(char *err, char *path);
// socket读数据
int anetRead(int fd, char *buf, int count);
// 解析所有的东西
int anetResolve(char *err, char *host, char *ipbuf, size_t ipbuf_len);
// 解析ip
int anetResolveIP(char *err, char *host, char *ipbuf, size_t ipbuf_len);
// ipv4下socket()函数创建socket
int anetTcpServer(char *err, int port, char *bindaddr, int backlog);
// ipv6下create socket
int anetTcp6Server(char *err, int port, char *bindaddr, int backlog);
// unix create socket and bind
int anetUnixServer(char *err, char *path, mode_t perm, int backlog);
// tcp socket accept()
int anetTcpAccept(char *err, int serversock, char *ip, size_t ip_len, int *port);
// unix socket accept()
int anetUnixAccept(char *err, int serversock);
// socket write data to buffer
int anetWrite(int fd, char *buf, int count);
// set socket to non-block mode
int anetNonBlock(char *err, int fd);
// set socket to block mode
int anetBlock(char *err, int fd);
// set socket mode to tcp_nodelay
int anetEnableTcpNoDelay(char *err, int fd);
// shutdown tcp_nodelay mode
int anetDisableTcpNoDelay(char *err, int fd);
// open keepalive mode
int anetTcpKeepAlive(char *err, int fd);
// set socket send timeout value
int anetSendTimeout(char *err, int fd, long long ms);
int anetPeerToString(int fd, char *ip, size_t ip_len, int *port);
int anetKeepAlive(char *err, int fd, int interval);
// get socket port and name
int anetSockName(int fd, char *ip, size_t ip_len, int *port);
int anetFormatAddr(char *fmt, size_t fmt_len, char *ip, int port);
int anetFormatPeer(int fd, char *fmt, size_t fmt_len);
int anetFormatSock(int fd, char *fmt, size_t fmt_len);

根据上面的接口名称和注释,做过网络编程的同学就能很快发现redis的anet部分只是对tcp socket api接口的一次封装。

其中有几个主要的方法根据我自己的理解进行分析:

设置tcp_nodelay的方法包装成了连个接口,分别是打开与关闭

static int anetSetTcpNoDelay(char *err, int fd, int val)
{if (setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof(val)) == -1){anetSetError(err, "setsockopt TCP_NODELAY: %s", strerror(errno));return ANET_ERR;}return ANET_OK;
}
int anetEnableTcpNoDelay(char *err, int fd)
{return anetSetTcpNoDelay(err, fd, 1);
}int anetDisableTcpNoDelay(char *err, int fd)
{return anetSetTcpNoDelay(err, fd, 0);
}

使用者根据自己的实际情况选择合适的调用接口。

里面有个ipv4和ipv6的考虑挺周全的,接口如下:

int anetGenericResolve(char *err, char *host, char *ipbuf, size_t ipbuf_len,int flags)
{struct addrinfo hints, *info;int rv;memset(&hints,0,sizeof(hints));if (flags & ANET_IP_ONLY) hints.ai_flags = AI_NUMERICHOST;hints.ai_family = AF_UNSPEC;hints.ai_socktype = SOCK_STREAM;  /* specify socktype to avoid dups */// hostname infoif ((rv = getaddrinfo(host, NULL, &hints, &info)) != 0) {anetSetError(err, "%s", gai_strerror(rv));return ANET_ERR;}if (info->ai_family == AF_INET) {// ipv4struct sockaddr_in *sa = (struct sockaddr_in *)info->ai_addr;inet_ntop(AF_INET, &(sa->sin_addr), ipbuf, ipbuf_len);} else {// IPv6的解法struct sockaddr_in6 *sa = (struct sockaddr_in6 *)info->ai_addr;inet_ntop(AF_INET6, &(sa->sin6_addr), ipbuf, ipbuf_len);}freeaddrinfo(info);return ANET_OK;
}

一般情况下,自己编程时只考虑到了ipv4的情况,但是未考虑ipv6的情况,现在看这些代码觉得作者还是挺细心周到的。

总体感觉这部分内容比较容易,暂时写到这里。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/463444.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

使用AJAX Toolkit创建新闻列表

我们很多站点上面都需要显示新闻列表,由标题和正文组成的。一般客户都希望实现这样的效果: 开始的时候只是显示标题,当点击标题的时候,再展开正文。再点击,又可缩回去。 这是典型的AJAX效果,或者说以前你也…

C语言 嵌入式 面试小知识点(一)

sizeof是C/C中的一个操作符(operator),简单的说其作用就是返回一个对象或者类型所占的内存字节数。 与strlen的区别: 一、sizeof 是运算符,确切的说是一个编译时运算符,参数可以是数组、指针、类型、对象…

将数据渲染到页面的几种方式

将数据渲染到页面的几种方式: 1.字符串拼接; 2.dom回流 3.文档碎片(文档碎片节点:documentFragment) 4.模板 (下章会详细介绍模板)转载于:https://www.cnblogs.com/shangjun6/p/1039740…

论证是一门学问

本文的标题借用了安东尼.韦斯顿(Anthony Weston)的《论证是一门学问》一书的标题,向安东尼老爷子致敬的同时,也希望更多人能够真正了解“什么是论证”。 争论与论证从来都不是新鲜事物,作为软件行业的科技工作者&…

[翻译]SQL Server 工作集消息

Q:我发现有指向工作集(SQL Server保留内存区域)被分页出来相关的消息: 重要部分的 SQL 服务器进程内存已被分页。这可能导致性能下降。持续时间: 0 秒。 工作集 (KB): 2484,已提交 (KB): 48036&…

Redis源码分析之工具类util

在redis源码中的辅助工具类中,主要包括大小端转换、SHA算法以及util.h中对应的算法。 大小端转换: LittleEndian:低位字节数据存放于低地址,高位字节数据存放于高地址。 BigEndian:低位字节数据存放于高地址&#x…

Linux下如何安装软件

一、解析Linux应用软件安装包通常Linux应用软件的安装包有三种:1) tar包,如software-1.2.3-1.tar.gz。它是使用UNIX系统的打包工具tar打包的。2) rpm包,如software-1.2.3-1.i386.rpm。它是RedHat Linux提供的一种包封装…

Python深浅拷贝辨析

1 import copy2 3 list1 [11, 22, [33, 44]]4 list2 list15 list3 list1[:]6 list4 copy.copy(list1)7 list5 copy.deepcopy(list1)8 9 list1[0] 0 # 对列表的首层做增删改查操作 10 print("list1:",id(list1),list1) # list1: 1455502266696 [0, 22, […

生活规则

1.朋友请你吃饭,不要觉得理所当然,请礼尚往来,否则你的名声会越来越臭。 2.给自己定目标,一年,两年,五年,也许你出生不如别人好,通过努力,往往可以改变70%的命运。破罐子…

[AX]AX2012 SSRS报表使用Report Data Method

在AX2012的SSRS报表中可以使用c#或者Visual basic .net编写report data method来获取和操作数据,由report data method返回的数据可以用在报表的表达式中,也可以用作dataset的数据源。 使用Report data method首先需要创建AX model工程,在工程…

HIVE和HBASE区别

转载:https://www.cnblogs.com/justinzhang/p/4273470.html 1. 两者分别是什么? Apache Hive是一个构建在Hadoop基础设施之上的数据仓库。通过Hive可以使用HQL语言查询存放在HDFS上的数据。HQL是一种类SQL语言,这种语言最终被转化为Map/Re…

php调试

今天在使用php 的session 的时候,出现了以前就遇见但是又解决不了的问题,在页面上出现如下提示: Warning: session_start() [function.session-start]: Cannot send session cache limiter - headers already sent (output started at E:\php…

C 结构体

C 结构体C 数组允许定义可存储相同类型数据项的变量,结构是 C 编程中另一种用户自定义的可用的数据类型,它允许您存储不同类型的数据项。结构用于表示一条记录,假设您想要跟踪图书馆中书本的动态,您可能需要跟踪每本书的下列属性&…

lightoj1259 线性筛的另一种写法 v变成bool标记数组

也是用线性筛&#xff0c;但是v用int会爆&#xff0c;所以这个线性筛用的是另外一种写法 #include<cstdio> #include<cmath> #include<queue> #include<vector> #include<cstring> #include<iostream> #include<algorithm> using na…

Redis基数统计之HyperLogLog小内存大用处

转载&#xff1a;https://blog.csdn.net/azhegps/article/details/71158952 我们一直都知道&#xff0c;redis几大常用数据结构&#xff0c;字符串、散列、列表、集合、有序集合。其实后来Redis做了很多补充&#xff0c;其中之一就是HyperLogLog&#xff0c;另外的还有GEO&…

matlab中的qr函数

转自&#xff1a;https://blog.csdn.net/qq278672818/article/details/62038630 实数矩阵A的QR分解是把A分解为A QR这里的Q是正交矩阵&#xff08;意味着QTQ I&#xff09;而R是上三角矩阵。类似的&#xff0c;我们可以定义A的QL, RQ和LQ分解。更一般的说&#xff0c;我们可以…

(String) 和 String.valueOf() 两种字符串转换的区别

使用 String.valueOf() 进行数据转换&#xff0c;如果被转换的数据为 null, 则这种方法将返回一个 "null" 字符串 &#xff08;String&#xff09; 方法进行转换时&#xff0c;如果被转换的数据为 null, 则返回 null 对象而不是一个 "null" 字符串。转载于…

利用有名管道实现进程间的通信

1 /*****************************************************************2 * Copyright (C) 2018 FBI WARNING. All rights reserved.3 * 4 * 文件名称&#xff1a;fifo_write.c5 * 创 建 者&#xff1a;constantine6 * 创建日期&#xff1a;2018年02月26日7 * 描 …

为什么分布式一定要有redis,redis的一些优缺点

1、为什么使用redis 分析:博主觉得在项目中使用redis&#xff0c;主要是从两个角度去考虑:性能和并发。当然&#xff0c;redis还具备可以做分布式锁等其他功能&#xff0c;但是如果只是为了分布式锁这些其他功能&#xff0c;完全还有其他中间件(如zookpeer等)代替&#xff0c;…

Google protobuf使用技巧和经验

Google protobuf是非常出色的开源工具&#xff0c;在项目中可以用它来作为服务间数据交互的接口&#xff0c;例如rpc服务、数据文件传输等。protobuf为proto文件中定义的对象提供了标准的序列化和反序列化方法&#xff0c;可以很方便的对pb对象进行各种解析和转换。以下是我总结…