Swoole 源码分析——Server模块之初始化

前言

本节主要介绍 server 模块进行初始化的代码，关于初始化过程中，各个属性的意义，可以参考官方文档：

SERVER 配置选项

关于初始化过程中，用于监听的 socket 绑定问题，可以参考：

UNP 学习笔记——基本 TCP 套接字编程

UNP 学习笔记——套接字选项

构造 server 对象

构造 server 对象最重要的是两件事：swServer_init 初始化 server、为 server 添加端口：

PHP_METHOD(swoole_server, __construct)
{zend_size_t host_len = 0;char *serv_host;long sock_type = SW_SOCK_TCP;long serv_port = 0;long serv_mode = SW_MODE_PROCESS;swServer *serv = sw_malloc(sizeof (swServer));swServer_init(serv);serv->factory_mode = serv_mode;if (serv_port == 0 && strcasecmp(serv_host, "SYSTEMD") == 0){if (swserver_add_systemd_socket(serv) <= 0){swoole_php_fatal_error(E_ERROR, "failed to add systemd socket.");return;}}else{swListenPort *port = swServer_add_port(serv, sock_type, serv_host, serv_port);}
}

swServer_init 函数

  • swServer_init 函数主要为 serv 对象赋值初值，如果想要更改 serv 对象各个属性，可以调用 set 函数
  • serv->gs 是全局共享内存
void swServer_init(swServer *serv)
{swoole_init();bzero(serv, sizeof(swServer));serv->factory_mode = SW_MODE_BASE;serv->reactor_num = SW_REACTOR_NUM > SW_REACTOR_MAX_THREAD ? SW_REACTOR_MAX_THREAD : SW_REACTOR_NUM;serv->dispatch_mode = SW_DISPATCH_FDMOD;serv->worker_num = SW_CPU_NUM;serv->max_connection = SwooleG.max_sockets < SW_SESSION_LIST_SIZE ? SwooleG.max_sockets : SW_SESSION_LIST_SIZE;serv->max_request = 0;serv->max_wait_time = SW_WORKER_MAX_WAIT_TIME;//http serverserv->http_parse_post = 1;serv->upload_tmp_dir = sw_strdup("/tmp");//heartbeat checkserv->heartbeat_idle_time = SW_HEARTBEAT_IDLE;serv->heartbeat_check_interval = SW_HEARTBEAT_CHECK;serv->buffer_input_size = SW_BUFFER_INPUT_SIZE;serv->buffer_output_size = SW_BUFFER_OUTPUT_SIZE;serv->task_ipc_mode = SW_TASK_IPC_UNIXSOCK;/*** alloc shared memory*/serv->stats = SwooleG.memory_pool->alloc(SwooleG.memory_pool, sizeof(swServerStats));if (serv->stats == NULL){swError("[Master] Fatal Error: failed to allocate memory for swServer->stats.");}serv->gs = SwooleG.memory_pool->alloc(SwooleG.memory_pool, sizeof(swServerGS));if (serv->gs == NULL){swError("[Master] Fatal Error: failed to allocate memory for swServer->gs.");}SwooleG.serv = serv;
}

swoole_init 函数

  • swoole_init 函数用于初始化全局变量 SwooleG 的各个属性
  • SwooleGS 是全局的共享内存
  • SwooleTG 是线程特有数据，每个线程都有自己独特的数据
extern swServerG SwooleG;              //Local Global Variable
extern SwooleGS_t *SwooleGS;           //Share Memory Global Variable
extern __thread swThreadG SwooleTG;   //Thread Global Variabletypedef struct
{swLock lock;swLock lock_2;
} SwooleGS_t;void swoole_init(void)
{struct rlimit rlmt;if (SwooleG.running){return;}bzero(&SwooleG, sizeof(SwooleG));bzero(&SwooleWG, sizeof(SwooleWG));bzero(sw_error, SW_ERROR_MSG_SIZE);SwooleG.running = 1;SwooleG.enable_coroutine = 1;sw_errno = 0;SwooleG.log_fd = STDOUT_FILENO;SwooleG.cpu_num = sysconf(_SC_NPROCESSORS_ONLN);SwooleG.pagesize = getpagesize();SwooleG.pid = getpid();SwooleG.socket_buffer_size = SW_SOCKET_BUFFER_SIZE;#ifdef SW_DEBUGSwooleG.log_level = 0;
#elseSwooleG.log_level = SW_LOG_INFO;
#endif//get system unameuname(&SwooleG.uname);//random seedsrandom(time(NULL));//init global shared memorySwooleG.memory_pool = swMemoryGlobal_new(SW_GLOBAL_MEMORY_PAGESIZE, 1);if (SwooleG.memory_pool == NULL){printf("[Master] Fatal Error: global memory allocation failure.");exit(1);}SwooleGS = SwooleG.memory_pool->alloc(SwooleG.memory_pool, sizeof(SwooleGS_t));if (SwooleGS == NULL){printf("[Master] Fatal Error: failed to allocate memory for SwooleGS.");exit(2);}//init global lockswMutex_create(&SwooleGS->lock, 1);swMutex_create(&SwooleGS->lock_2, 1);swMutex_create(&SwooleG.lock, 0);if (getrlimit(RLIMIT_NOFILE, &rlmt) < 0){swWarn("getrlimit() failed. Error: %s[%d]", strerror(errno), errno);SwooleG.max_sockets = 1024;}else{SwooleG.max_sockets = (uint32_t) rlmt.rlim_cur;}SwooleTG.buffer_stack = swString_new(8192);if (SwooleTG.buffer_stack == NULL){exit(3);}if (!SwooleG.task_tmpdir){SwooleG.task_tmpdir = sw_strndup(SW_TASK_TMP_FILE, sizeof(SW_TASK_TMP_FILE));SwooleG.task_tmpdir_len = sizeof(SW_TASK_TMP_FILE);}char *tmp_dir = swoole_dirname(SwooleG.task_tmpdir);//create tmp dirif (access(tmp_dir, R_OK) < 0 && swoole_mkdir_recursive(tmp_dir) < 0){swWarn("create task tmp dir(%s) failed.", tmp_dir);}if (tmp_dir){sw_free(tmp_dir);}//init signalfd
#ifdef HAVE_SIGNALFDswSignalfd_init();SwooleG.use_signalfd = 1;SwooleG.enable_signalfd = 1;
#endif//timerfd
#ifdef HAVE_TIMERFDSwooleG.use_timerfd = 1;
#endifSwooleG.use_timer_pipe = 1;
}

swServer_add_port 函数

  • swServer_add_port 函数为服务端添加监听的端口
  • 首先需要检测 listen_port_num 已监听的端口不能大于 SW_MAX_LISTEN_PORT(默认为 60000)
  • 如果 socket 的类型不是 unix sock，那么端口号必须大于等于 0，小于 65535
  • host 主域名长度也不能大于 SW_HOST_MAXSIZE(104)
  • 然后从共享内存池中申请一个 swListenPort 类型的对象，然后调用 swPort_init 对端口对象进行初始化
  • 利用函数 swSocket_create 创建一个 socket 对象，并返回其文件描述符
  • 调用 swSocket_bind 函数将 socket 绑定到对应的主域与端口上来
  • 如果协议是数据报(UDP)，而不是数据流时，需要设置 socket 的发送缓存与接收缓存为 socket_buffer_size
  • 设置 socket 为非阻塞、O_CLOEXEC(exec 之后文件描述符自动关闭)
  • 根据协议类型设置 have_udp_sock、have_tcp_sock、udp_socket_ipv4/udp_socket_ipv6 等等属性
  • 递增 listen_port_num ，向单链表 listen_list 中添加 swListenPort 对象
enum swSocket_type
{SW_SOCK_TCP          =  1,SW_SOCK_UDP          =  2,SW_SOCK_TCP6         =  3,SW_SOCK_UDP6         =  4,SW_SOCK_UNIX_DGRAM   =  5,  //unix sock dgramSW_SOCK_UNIX_STREAM  =  6,  //unix sock stream
};swListenPort* swServer_add_port(swServer *serv, int type, char *host, int port)
{if (serv->listen_port_num >= SW_MAX_LISTEN_PORT){swoole_error_log(SW_LOG_ERROR, SW_ERROR_SERVER_TOO_MANY_LISTEN_PORT, "allows up to %d ports to listen", SW_MAX_LISTEN_PORT);return NULL;}if (!(type == SW_SOCK_UNIX_DGRAM || type == SW_SOCK_UNIX_STREAM) && (port < 0 || port > 65535)){swoole_error_log(SW_LOG_ERROR, SW_ERROR_SERVER_INVALID_LISTEN_PORT, "invalid port [%d]", port);return NULL;}if (strlen(host) + 1  > SW_HOST_MAXSIZE){swoole_error_log(SW_LOG_ERROR, SW_ERROR_NAME_TOO_LONG, "address '%s' exceeds %d characters limit", host, SW_HOST_MAXSIZE - 1);return NULL;}swListenPort *ls = SwooleG.memory_pool->alloc(SwooleG.memory_pool, sizeof(swListenPort));if (ls == NULL){swError("alloc failed");return NULL;}swPort_init(ls);ls->type = type;ls->port = port;strncpy(ls->host, host, strlen(host) + 1);if (type & SW_SOCK_SSL){type = type & (~SW_SOCK_SSL);if (swSocket_is_stream(type)){ls->type = type;ls->ssl = 1;
#ifdef SW_USE_OPENSSLls->ssl_config.prefer_server_ciphers = 1;ls->ssl_config.session_tickets = 0;ls->ssl_config.stapling = 1;ls->ssl_config.stapling_verify = 1;ls->ssl_config.ciphers = sw_strdup(SW_SSL_CIPHER_LIST);ls->ssl_config.ecdh_curve = sw_strdup(SW_SSL_ECDH_CURVE);
#endif}}//create server socketint sock = swSocket_create(ls->type);if (sock < 0){swSysError("create socket failed.");return NULL;}//bind address and portif (swSocket_bind(sock, ls->type, ls->host, &ls->port) < 0){close(sock);return NULL;}//dgram socket, setting socket buffer sizeif (swSocket_is_dgram(ls->type)){setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &ls->socket_buffer_size, sizeof(int));setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &ls->socket_buffer_size, sizeof(int));}//O_NONBLOCK & O_CLOEXECswoole_fcntl_set_option(sock, 1, 1);ls->sock = sock;if (swSocket_is_dgram(ls->type)){serv->have_udp_sock = 1;serv->dgram_port_num++;if (ls->type == SW_SOCK_UDP){serv->udp_socket_ipv4 = sock;}else if (ls->type == SW_SOCK_UDP6){serv->udp_socket_ipv6 = sock;}}else{serv->have_tcp_sock = 1;}LL_APPEND(serv->listen_list, ls);serv->listen_port_num++;return ls;
}

swPort_init 函数

  • swPort_init 函数用于初始化 swListenPort 对象
  • backlog、tcp_keepcount、tcp_keepidle 等等都是相应 socket 的属性
  • 在外网通信时，有些客户端发送数据的速度较慢，每次只能发送一小段数据。这样 onReceive 到的数据就不是一个完整的包。 还有些客户端是逐字节发送数据的，如果每次回调 onReceive 会拖慢整个系统。Length_Check 和 EOF_Check 的使用。package_length_type、package_eof 等等就是相关参数的具体参数。
#define SW_DATA_EOF                "\r\n\r\n"void swPort_init(swListenPort *port)
{port->sock = 0;port->ssl = 0;//listen backlogport->backlog = SW_BACKLOG;//tcp keepaliveport->tcp_keepcount = SW_TCP_KEEPCOUNT;port->tcp_keepinterval = SW_TCP_KEEPINTERVAL;port->tcp_keepidle = SW_TCP_KEEPIDLE;port->open_tcp_nopush = 1;port->protocol.package_length_type = 'N';port->protocol.package_length_size = 4;port->protocol.package_body_offset = 4;port->protocol.package_max_length = SW_BUFFER_INPUT_SIZE;port->socket_buffer_size = SwooleG.socket_buffer_size;char eof[] = SW_DATA_EOF;port->protocol.package_eof_len = sizeof(SW_DATA_EOF) - 1;memcpy(port->protocol.package_eof, eof, port->protocol.package_eof_len);
}
  • c：有符号、1字节
  • C：无符号、1字节
  • s ：有符号、主机字节序、2字节
  • S：无符号、主机字节序、2字节
  • n：无符号、网络字节序、2字节
  • N：无符号、网络字节序、4字节
  • l：有符号、主机字节序、4字节（小写L）
  • L：无符号、主机字节序、4字节（大写L）
  • v：无符号、小端字节序、2字节
  • V：无符号、小端字节序、4字节

swSocket_create 创建 socket

swSocket_create 函数会根据 type 的类型来调用 socket 系统调用

int swSocket_create(int type)
{int _domain;int _type;switch (type){case SW_SOCK_TCP:_domain = PF_INET;_type = SOCK_STREAM;break;case SW_SOCK_TCP6:_domain = PF_INET6;_type = SOCK_STREAM;break;case SW_SOCK_UDP:_domain = PF_INET;_type = SOCK_DGRAM;break;case SW_SOCK_UDP6:_domain = PF_INET6;_type = SOCK_DGRAM;break;case SW_SOCK_UNIX_DGRAM:_domain = PF_UNIX;_type = SOCK_DGRAM;break;case SW_SOCK_UNIX_STREAM:_domain = PF_UNIX;_type = SOCK_STREAM;break;default:swWarn("unknown socket type [%d]", type);return SW_ERR;}return socket(_domain, _type, 0);
}

swSocket_bind 绑定端口

  • SO_REUSEADDR 允许启动一个监听服务器并捆绑众所周知端口，即使以前建立的该端口用作它们的本地端口的连接仍存在。

    • 如果不对TCP的套接字选项进行任何限制时，如果启动两个进程，第二个进程就会在调用bind函数的时候出错（Address already in use）。
    • 如果在调用bind之前我们设置了SO_REUSEADDR，但是不在第二个进程启动前close这个套接字，那么第二个进程仍然会在调用bind函数的时候出错（Address already in use）。
    • 如果在调用bind之前我们设置了SO_REUSEADDR，并接收了一个客户端连接，并且在第二个进程启动前关闭了bind的套接字，这个时候第一个进程只拥有一个套接字（与客户端的连接），那么第二个进程则可以bind成功，符合预期。
  • 相对 SO_REUSEADDR 来说，SO_REUSEPORT 没有那么多的限制条件，允许两个毫无血缘关系的进程使用相同的 IP 地址同时监听同一个端口，并且不会出现惊群效应
  • 对于 UNIX SOCKET，需要设置 sun_family 与 sun_path
  • 对于 IPV4，需要设置 sin_family、sin_port、sin_addr;对于 IPV6，需要设置 sin6_family、sin6_port、sin6_addr，然后调用 bind 函数;
  • 如果 port 为0，说明服务器绑定的是任意端口，bind 函数会将系统所选择的端口返回给 sockaddr 对象
int swSocket_bind(int sock, int type, char *host, int *port)
{int ret;struct sockaddr_in addr_in4;struct sockaddr_in6 addr_in6;struct sockaddr_un addr_un;socklen_t len;//SO_REUSEADDR optionint option = 1;if (setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &option, sizeof(int)) < 0){swoole_error_log(SW_LOG_WARNING, SW_ERROR_SYSTEM_CALL_FAIL, "setsockopt(%d, SO_REUSEADDR) failed.", sock);}//reuse port
#ifdef HAVE_REUSEPORTif (SwooleG.reuse_port){if (setsockopt(sock, SOL_SOCKET, SO_REUSEPORT, &option, sizeof(int)) < 0){swSysError("setsockopt(SO_REUSEPORT) failed.");SwooleG.reuse_port = 0;}}
#endif//unix socketif (type == SW_SOCK_UNIX_DGRAM || type == SW_SOCK_UNIX_STREAM){bzero(&addr_un, sizeof(addr_un));unlink(host);addr_un.sun_family = AF_UNIX;strncpy(addr_un.sun_path, host, sizeof(addr_un.sun_path) - 1);ret = bind(sock, (struct sockaddr*) &addr_un, sizeof(addr_un));}//IPv6else if (type > SW_SOCK_UDP){bzero(&addr_in6, sizeof(addr_in6));inet_pton(AF_INET6, host, &(addr_in6.sin6_addr));addr_in6.sin6_port = htons(*port);addr_in6.sin6_family = AF_INET6;ret = bind(sock, (struct sockaddr *) &addr_in6, sizeof(addr_in6));if (ret == 0 && *port == 0){len = sizeof(addr_in6);if (getsockname(sock, (struct sockaddr *) &addr_in6, &len) != -1){*port = ntohs(addr_in6.sin6_port);}}}//IPv4else{bzero(&addr_in4, sizeof(addr_in4));inet_pton(AF_INET, host, &(addr_in4.sin_addr));addr_in4.sin_port = htons(*port);addr_in4.sin_family = AF_INET;ret = bind(sock, (struct sockaddr *) &addr_in4, sizeof(addr_in4));if (ret == 0 && *port == 0){len = sizeof(addr_in4);if (getsockname(sock, (struct sockaddr *) &addr_in4, &len) != -1){*port = ntohs(addr_in4.sin_port);}}}//bind failedif (ret < 0){swoole_error_log(SW_LOG_WARNING, SW_ERROR_SYSTEM_CALL_FAIL, "bind(%s:%d) failed. Error: %s [%d]", host, *port, strerror(errno), errno);return SW_ERR;}return ret;
}

swoole_fcntl_set_option 函数为文件描述符设置选项

  • 此函数主要是利用 fcntl 函数为文件描述符设置阻塞/非阻塞、CLOEXEC 等属性。
void swoole_fcntl_set_option(int sock, int nonblock, int cloexec)
{int opts, ret;if (nonblock >= 0){do{opts = fcntl(sock, F_GETFL);}while (opts < 0 && errno == EINTR);if (opts < 0){swSysError("fcntl(%d, GETFL) failed.", sock);}if (nonblock){opts = opts | O_NONBLOCK;}else{opts = opts & ~O_NONBLOCK;}do{ret = fcntl(sock, F_SETFL, opts);}while (ret < 0 && errno == EINTR);if (ret < 0){swSysError("fcntl(%d, SETFL, opts) failed.", sock);}}#ifdef FD_CLOEXECif (cloexec >= 0){do{opts = fcntl(sock, F_GETFD);}while (opts < 0 && errno == EINTR);if (opts < 0){swSysError("fcntl(%d, GETFL) failed.", sock);}if (cloexec){opts = opts | FD_CLOEXEC;}else{opts = opts & ~FD_CLOEXEC;}do{ret = fcntl(sock, F_SETFD, opts);}while (ret < 0 && errno == EINTR);if (ret < 0){swSysError("fcntl(%d, SETFD, opts) failed.", sock);}}
#endif
}

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

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

相关文章

linux下搭建git服务器

linux下搭建git服务器

安装 Git Linux 做为服务器端系统&#xff0c;Windows 作为客户端系统&#xff0c;分别安装 Git 服务器端&#xff1a; #yum install -y git 安装完后&#xff0c;查看 Git 版本 [rootlocalhost ~]# git --version git version 1.7.1 客户端&#xff1a; 下载 Git for Windows&…
阅读更多...
逻辑综合——工艺库

逻辑综合——工艺库

一、库文件的设置 运行DC时需要用到的库文件有&#xff1a;目标库&#xff08;target library&#xff09;、链接库&#xff08;link library&#xff09;、符号库&#xff08;symbol library&#xff09;、算术运算库&#xff08;synthetic library&#xff09;。 1、目标库…
阅读更多...
[COGS 0065][NOIP 2002] 字串变换

[COGS 0065][NOIP 2002] 字串变换

65. [NOIP2002] 字串变换 ★★ 输入文件&#xff1a;string.in 输出文件&#xff1a;string.out 简单对比时间限制&#xff1a;1 s 内存限制&#xff1a;128 MB [问题描述] 已知有两个字串A\$, B\$及一组字串变换的规则&#xff08;至多6个规则&#xff09;: A1\$ ->…
阅读更多...
逻辑综合——施加约束

逻辑综合——施加约束

Design Compiler时一个约束驱动&#xff08;constraint-driven&#xff09;的综合工具&#xff0c;它的结果与设计者施加的约束条件密切相关。 一、面积约束 进行面积的约束&#xff0c;也就是告诉DC综合的电路面积要在多少以内。在介绍约束命令之前&#xff0c;先了解一下面积…
阅读更多...
[Codevs] 1004 四子连棋

[Codevs] 1004 四子连棋

1004 四子连棋 时间限制: 1 s空间限制: 128000 KB题目等级 : 黄金 Gold题目描述 Description在一个4*4的棋盘上摆放了14颗棋子&#xff0c;其中有7颗白色棋子&#xff0c;7颗黑色棋子&#xff0c;有两个空白地带&#xff0c;任何一颗黑白棋子都可以向上下左右四个方向移动到相邻…
阅读更多...
逻辑综合——优化电路

逻辑综合——优化电路

对进行时序路径、工作环境、设计规则等进行约束完成之后&#xff0c;DC就可以进行综合、优化时序了&#xff0c;DC在优化过程中主要的策略将在下面进行说明。然而&#xff0c;当普通模式下不能进行优化的&#xff0c;就需要我们进行编写脚本来改进DC的优化来达到时序要求。 DC…
阅读更多...
DOM包裹wrap()方法

DOM包裹wrap()方法

DOM包裹wrap()方法 如果要将元素用其他元素包裹起来&#xff0c;也就是给它增加一个父元素&#xff0c;针对这样的处理&#xff0c;JQuery提供了一个wrap方法 .wrap( wrappingElement )&#xff1a;在集合中匹配的每个元素周围包裹一个HTML结构 简单的看一段代码&#xff1a; &…
阅读更多...
Verdi 基础教程

Verdi 基础教程

一、Verdi 功能 查看设计debugVerdi不能自己产生波形 二、Verdi使用流程 1、Verdi环境配置 .bashrc中配置 export Verdi_HOME$Synopsys_Dir/Verdi2015 #export NOVAS_HOME$Synopsys_Dir/Verdi2015 export PATH$Verdi_HOME/bin:$PATH export LD_LIBRARY_PATH"/opt/Syno…
阅读更多...
ida和idr机制分析（盘符分配机制）

ida和idr机制分析（盘符分配机制）

内核ida和idr机制分析&#xff08;盘符分配机制&#xff09; ida和idr的机制在我个人看来&#xff0c;是内核管理整数资源的一种方法。在内核中&#xff0c;许多地方都用到了该结构&#xff08;例如class的id&#xff0c;disk的id&#xff09;&#xff0c;更直观的说&#xff0…
阅读更多...
MIPI CSI-2学习

MIPI CSI-2学习

CSI&#xff08;Camera Serial Interface&#xff09;定义了摄像头外设与主机控制器之间的接口&#xff0c;旨在确定摄像头与主机控制器在移动应用中的标准。 关键词描述 缩写解释CCICamera Control Interface&#xff08;物理层组件&#xff0c;通常使用I2C或I3C进行通信&…
阅读更多...
u-boot_NAND_Flash操作命令及烧录Linux内核和文件系统

u-boot_NAND_Flash操作命令及烧录Linux内核和文件系统

阅读更多...
nand flash坏块管理OOB,BBT,ECC

nand flash坏块管理OOB,BBT,ECC

0.NAND的操作管理方式 NAND FLASH的管理方式&#xff1a;以三星FLASH为例&#xff0c;一片Nand flash为一个设备(device)&#xff0c;1 (Device) xxxx (Blocks)&#xff0c;1 (Block) xxxx (Pages)&#xff0c;1(Page) 528 (Bytes) 数据块大小(512Bytes) OOB 块大小(16Byte…
阅读更多...
小白学git2

小白学git2

你已经在本地创建了一个Git仓库后&#xff0c;又想在GitHub创建一个Git仓库&#xff0c;并且让这两个仓库进行远程同步&#xff0c;这样&#xff0c;GitHub上的仓库既可以作为备份&#xff0c;又可以让其他人通过该仓库来协作&#xff0c;真是一举多得。 首先&#xff0c;登陆G…
阅读更多...
CMOS图像传感器——工作原理

CMOS图像传感器——工作原理

一、像素阵列结构 一般像素阵列是由水平方向的行（ Row ） 和垂直方向的列（Column）正交排列构成的。像素排列的最基本设计原则是：摄像器件像素排列的坐标，必须在显示的时候能够准确地还原在图像原来的相对位置上。在大多数情况下，每个像素中心线在行的方向和列的方向，即…
阅读更多...
追寻终极数据库 - 事务/分析混合处理系统的交付挑战 （3）

追寻终极数据库 - 事务/分析混合处理系统的交付挑战 （3）

挑战&#xff1a;支持多个存储引擎 以下内容并不是新发现&#xff1a;行优化存储适用于OLTP和运营工作负载&#xff0c;而列存储适用于BI和分析工作负载。频繁写入的工作负载适用于行式存储。对Hadoop而言&#xff0c;Hbase适合低延迟工作负载&#xff0c;列式ORC文件或Parquet…
阅读更多...
异步FIFO设计（Verilog）

异步FIFO设计（Verilog）

FIFO&#xff08;First In First Out&#xff09;是异步数据传输时经常使用的存储器。该存储器的特点是数据先进先出&#xff08;后进后出&#xff09;。其实&#xff0c;多位宽数据的异步传输问题&#xff0c;无论是从快时钟到慢时钟域&#xff0c;还是从慢时钟到快时钟域&…
阅读更多...
python中RabbitMQ的使用（路由键模糊匹配）

python中RabbitMQ的使用（路由键模糊匹配）

路由键模糊匹配 使用正则表达式进行匹配。其中“#”表示所有、全部的意思&#xff1b;“*”只匹配到一个词。 匹配规则&#xff1a; 路由键&#xff1a;routings [ happy.work, happy.life , happy.work.teacher, sad.work, sad.life, sad.work.teacher ] "#"&am…
阅读更多...
时钟切换处理（Verilog）

时钟切换处理（Verilog）

随着各种应用场景的限制&#xff0c;芯片在运行时往往需要在不同的应用下切换不同的时钟源&#xff0c;例如低功耗和高性能模式就分别需要低频率和高频率的时钟。两个时钟源有可能是同源且同步的&#xff0c;也有可能是不相关的。直接使用选择逻辑进行时钟切换大概率会导致分频…
阅读更多...
Angular Elements 组件在非angular 页面中使用的DEMO

Angular Elements 组件在非angular 页面中使用的DEMO

2019独角兽企业重金招聘Python工程师标准>>> 一、Angular Elements 介绍 Angular Elements 是伴随Angular6.0一起推出的新技术。它借助Chrome浏览器的ShadowDom API&#xff0c;实现一种自定义组件。 这种组件可以用Angular普通组件的开发技术进行编写&#xff0c;…
阅读更多...
卢卡斯定理

卢卡斯定理

卢卡斯定理:解决一类组合数取模问题 A、B是非负整数&#xff0c;p是质数。AB写成p进制&#xff1a;Aa[n]a[n-1]...a[0]&#xff0c;Bb[n]b[n-1]...b[0]。 则组合数C(A,B)与C(a[n],b[n])*C(a[n-1],b[n-1])*...*C(a[0],b[0]) modp同余 即&#xff1a;Lucas(n,m,p)c(n%p,m%p)*Luc…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发 尧图建网站