skynet 入门篇

news2024/11/13 12:57:31

文章目录

  • 概述
    • 1.实现了actor模型
    • 2.实现了服务器的基础组件
  • 环境准备
    • centos
    • ubuntu
    • mac
    • 编译安装
  • Actor
    • Actor模型
      • 定义
      • 组成
    • Actor调度
      • 工作线程流程
      • 工作线程权重
      • 工作线程执行规则
  • 小结

概述

skynet 是一个轻量级服务器框架,而不仅仅用于游戏;

轻量级有以下几个方面:

1.实现了actor模型

它实现了actor模型,以及相关的脚手架(工具集);

  1. actor间数据共享机制;
  2. c服务扩展机制;

2.实现了服务器的基础组件

它实现了服务器的基础组件;

  1. 实现了reactor并发网络库;并提供了大量连接的接入方案;
  2. 基于自身网络库,实现了常用的数据库驱动(异步连接方案),并融合了lua数据结构;
  3. 实现了网关服务
  4. 时间轮用于处理定时消息;

环境准备

centos

yum install -y git gcc readline-devel autoconf

ubuntu

apt-get install git build-essential readline-dev autoconf
# 或者
apt-get install git build-essential libreadline-dev autoconf

mac

brew install git gcc readline autoconf

编译安装

git clone https://github.com/cloudwu/skynet.git
cd skynet
# centos or ubuntu
make linux
# mac
make macosx

Actor

skynet采用c++ lua实现actor并发模型;底层也是通过采用多少个核心开启多少个内核线程来充分利用多核;

Actor模型

有消息的actor为活跃的actor,没有消息为非活跃的actor;

定义

  1. 用于并行计算
  2. Actor是最基本的计算单元
  3. 基于消息计算
  4. Actor通过消息进行沟通;

组成

  • 隔离的环境
    主要通过lua虚拟机来实现;
  • 消息队列
    用来存放有序(先后到达)的消息;
  • 回调函数
    用来运行Actor;从Actor的消息队列中取出消息,并作为该回调函数的参数来运行Actor;

Actor调度

actor的调度是由线程池的调度来驱动的;
线程池
在这里插入图片描述

工作线程流程

工作线程从全局队列中 pop 出单个 Actor 消息队列;从 Actor 消息队列中按照规则 pop 出一定
数量的消息进行执行;若 Actor 消息队列中仍有消息继续放入全局队列队尾;若 Actor 消息队列中
没有消息则不放入全局队列中;全局队列只存活跃的 Actor 消息队列;

工作线程权重

工作线程数量是按照 cpu 核心数来设置的;工作线程按照下面工作线程权重图来设置每个工作线
程的权重;

//工作线程权重图  32个核心
static int weight[] = { 
		-1, -1, -1, -1, 0, 0, 0, 0,
		1, 1, 1, 1, 1, 1, 1, 1, 
		2, 2, 2, 2, 2, 2, 2, 2, 
		3, 3, 3, 3, 3, 3, 3, 3, };

工作线程执行规则

在这里插入图片描述

从上面逻辑可以看出,当工作线程的权重为 -1 时,该工作线程每次只 pop 一条消息;当工作线
程的权重为 0 时,该工作线程每次消费完所有的消息;当工作线程的权重为 1 时,每次消费消息
队列中 的消息;当工作线程的权重为 2 时,每次消费消息队列中 的消息;以此类推;通过
这种方式,完成消息队列梯度消费,从而不至于让某些队列过长;这种消息调度的方式不是最优的
调度方式(相较于 go 语言),云风也在尝试修改更优的方式来调度;但是目前从多年线上实践情
况来看,skynet 运行良好;

小结

这一篇主要写了skynet的编译,运行;此外,还有Actor相关的一些,包括Actor模型,Actor调度相关的。算是个入门篇吧,对于skynet,早就听说过云风大神,最初学习lua也是看他写的一些教程。这次学习skynet,挺好的。发现了很多以前没有注意到的内容,有兴趣,可以一起学习学习。OK,结束了。

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

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

相关文章

16现代循环神经网络—深度循环与双向循环

目录 1.深度循环神经网络回顾:循环神经网络总结简洁代码实现2.双向循环神经网络隐马尔可夫模型中的动态规划双向模型模型的计算代价及其应用总结代码实现1.深度循环神经网络 回顾:循环神经网络 如何将循环神经网络变深,以获得更多的非线性? 通过添加多个隐藏层的方式来实现…

Transformer中的Multi-head与Self-Attention机制解析——从单一关注到多元自省的效益最大化

Transformer中的Multi-head与Self-Attention机制解析——从单一关注到多元自省的效益最大化 Multi-head Attention与Self-Attention的核心思想 想象一下,你在读一本书,你想要同时关注到书中的多个角色和情节。多头注意力机制就是让你能够同时关注到多个不…

day14:01函数参数的使用

一、形参与实参介绍 【形参】:在定义函数阶段定义的参数称之为形式参数,简称形参,相当于变量名 def func(x, y): # x1,y2print(x, y)【实参】:在调用函数阶段传入的值称之为实际参数,简称实参,相当于变量…

OpenEuler系统下——k8s离线安装部署

简介 K8S是目前已经是业界最为流行的开源技术框架,但是苦于其学习难度较大,并且初学者在开始的时候需要自己进行安装搭建部署,以供后续的学习使用,但是国内经常会出现无法访问外网的官方网站,导致很多镜像和依赖包无法…

uCore2020 lab1练习一作业

在线环境(无需搭建环境即可复现) 在线实验指导书uCore2020,有些章节无法访问 文章目录 lab1练习一1、操作系统镜像文件ucore.img生成过程init.o等文件的生成过程bin/kernal的生成过程bin/sign的生成过程bin/bootblock的生成过程bin/ucore.i…

搭建AI无人直播插件

在当今的数字时代,直播已成为一种极为流行的内容传播方式,而人工智能(AI)技术的飞速发展更是为直播行业注入了新的活力。 AI无人直播插件,作为这一趋势下的产物,不仅能够实现24小时不间断的直播内容生成,还能根据观众…

SpringCloud Alibaba 微服务(四):Sentinel

目录 前言 一、什么是Sentinel? Sentinel 的主要特性 Sentinel 的开源生态 二、Sentinel的核心功能 三、Sentinel 的主要优势与特性 1、丰富的流控规则 2、完善的熔断降级机制 3、实时监控和控制台 4、多数据源支持 5、扩展性强 四、Sentinel 与 Hystrix…

Redis 序列化 GenericJackson2JsonRedisSerializer和Jackson2JsonRedisSerializer的区别

GenericJackson2JsonRedisSerializer 和 Jackson2JsonRedisSerializer 是 Spring Data Redis 提供的两种基于 Jackson 的 Redis 序列化器。 它们的主要区别在于序列化和反序列化的方式以及适用的场景。 GenericJackson2JsonRedisSerializer 序列化方式:在序列化对…

为Mac配置Alfred

参考资料: Alfred神器使用手册 | louis blogMacOS神器之Alfred workflow概览GitHub - arpir/Alfred-Workflows-Collection: 一些好用的 Alfred Workflow 一、修改快捷键 Spotlight的默认快捷键是Command Space Alfred的默认快捷键是Option Space 可以将Alfred和…

[网络编程】网络编程的基础使用

系列文章目录 1、 初识网络 网络编程套接字 系列文章目录前言一、TCP和UDP协议的引入二、UDP网络编程1.Java中的UDP2.UDP回显代码案例3.UDP网络编程的注意事项 三、TCP网络编程1.TCP回显代码案例2.TCP多线程使用 总结 前言 在学习完基础的网络知识后,完成跨主机通…

关于 OSPF LSA 序列号范围 0x80000001-0x7FFFFFFF 释疑正本清源

注:机翻,未校对。 正本:RFC 2328 OSPF Version 2 中相关解释 April 1998 12.1.6. LS sequence number 12.1.6. 序列号 The sequence number field is a signed 32-bit integer. It is used to detect old and duplicate LSAs. The space …

set,map(java)

前言:要了解set和map,首先需要对搜索树和哈希有一定的了解,才能进一步深入的了解set和map。 1.搜索树 (1)性质: 若它的左子树不为空,则左子树上所有节点值都小于根节点的值。 若它的右子树不…

事件如何驱动图表运行

状态流图如何响应事件 Stateflow图表仅在以循环方式响应事件时执行。 由于图表在单个线程上运行,因此基于事件发生的操作对该事件是原子性的。图表中由事件引起的所有活动都在执行返回到接收事件之前发生的活动之前完成。一旦事件启动了一个操作,除非被…

全网最全程序员接单网站

程序员客栈-领先的程序员自由工作平台-程序员兼职 (proginn.com) 闲鱼 - 闲不住,上闲鱼! (goofish.com) 猪八戒网-品质企业服务 就找猪八戒 (zbj.com) 电鸭社区-专注远程工作招聘交流-远程工作,从电鸭开始 (eleduck.com) 开源众包-百万开发者…

Java台球厅助教教练预约上门到店系统源码

🎱一杆在手,天下我有!台球助教教练预约系统,让球技飙升不是梦🚀 🎯【开篇:台球爱好者的福音来啦!】🎯 还在为找不到合适的台球教练而烦恼吗?或是想要在家就…

代码实践思考:C++和Python

起因 在人工智能工具日益强大的今天 如何更高效的进行代码学习 如何借助智能工具实现代码转换? 是否直接可以使用?为何? 如何实现不同的编程语言之间代码的无损转换? x86与arm C 云课五分钟-02第一个代码复现-终端甜甜圈C-CS…

GEE错误——文件导出的时候出现Error: User memory limit exceeded. (Error code: 3)

错误简介 在试图将我的表导出到资产文件夹,但出现了内存错误。我不知道我做错了什么。相同的脚本适用于其他年份。文件导出的时候出现Error: User memory limit exceeded. (Error code: 3) 函数 reduceToVectors(reducer, geometry, scale, geometryType, eightConnected,…

雪花算法的一些问题解析

前言 最近做项目,有些老旧项目,需要生成分布式唯一ID,不允许重复,此时如果要对其他中间件和数据库依赖小,那么就需要一套固定的ID生成规则,雪花算法就正当合适,当时Twitter就是用来存储数据库I…

服务器主机安全有多重要

一、什么是主机安全 主机安全,作为维护计算机系统核心安全的基石,旨在全面捍卫硬件与软件免受任何未经授权的侵扰、篡改、数据泄露等安全挑战。这一过程不仅聚焦于数据存储与处理的保密性、完整性及可用性,还深入至硬件构造、固件层、以及系…

利用C++11的异步操作实现一个线程池

利用C11的异步操作实现一个线程池 利用C11的异步操作实现一个线程池 介绍关于一些代码细节的解释测试 介绍 基于线程池执行任务的时候,入口函数内部执行逻辑是固定的,因此选择std::packaged_task加上std::future的组合来实现。 具体使用可以见我上一…