前端技术
HTML
CSS
Javascript
前端框架和UI库
VUE
ReactJS
AngularJS
JQuery
NodeJS
JSON
Element-UI
Bootstrap
Material UI
服务端和客户端
Java
Python
PHP
Golang
Scala
Kotlin
Groovy
Ruby
Lua
.net
c#
c++
后端WEB和工程框架
SpringBoot
SpringCloud
Struts2
MyBatis
Hibernate
Tornado
Beego
Go-Spring
Go Gin
Go Iris
Dubbo
HessianRPC
Maven
Gradle
数据库
MySQL
Oracle
Mongo
中间件与web容器
Redis
MemCache
Etcd
Cassandra
Kafka
RabbitMQ
RocketMQ
ActiveMQ
Nacos
Consul
Tomcat
Nginx
Netty
大数据技术
Hive
Impala
ClickHouse
DorisDB
Greenplum
PostgreSQL
HBase
Kylin
Hadoop
Apache Pig
ZooKeeper
SeaTunnel
Sqoop
Datax
Flink
Spark
Mahout
数据搜索与日志
ElasticSearch
Apache Lucene
Apache Solr
Kibana
Logstash
数据可视化与OLAP
Apache Atlas
Superset
Saiku
Tesseract
系统与容器
Linux
Shell
Docker
Kubernetes
[Docker容器时钟同步问题]的搜索结果
这里是文章列表。热门标签的颜色随机变换,标签颜色没有特殊含义。
点击某个标签可搜索标签相关的文章。
点击某个标签可搜索标签相关的文章。
Docker
Docker 是一个非常普及的容器化技术,它能够让程序员在不同的环境中创建和执行应用程序。但是,有时候在使用 Docker 的过程中,我们也许会碰到一个非常奇怪的问题:时钟不正确。 在 Docker 容器中,时钟通常会在启动容器时自动与主机时钟同步化。但是,当我们在容器中执行持续执行的程序或者服务时,时钟也许会出现偏移或者不同步化的情况,这会导致程序产生异常或者错误。 这种情况的原因通常是容器内部的时钟与主机系统的时钟存在差异。当容器内的时钟发生偏移时,我们可以使用 Docker 提供的命令行工具来手动进行时钟同步化,例如: docker run --rm -it --privileged alpine /bin/sh hwclock -s 上述命令将登录 Alpine 容器,并使用 hwclock 命令将内部时钟与主机时钟同步化。在其它容器中,您可以使用相同的方法处理时钟不同步化的问题。 另外,如果您需要在容器中执行数据库或其它需要精确时间的应用程序时,您可以考虑使用特定的 Docker 镜像来处理时钟同步化问题,例如: docker run --rm -it --privileged centos /bin/sh yum -y install ntp ntpdate pool.ntp.org 上述命令将在 CentOS 容器中安装 NTP 服务,并使用 ntpdate 命令从 pool.ntp.org 同步化时钟。在其它镜像中,您也可以使用类似的方法来处理时钟同步化问题。 总而言之,时钟不正确是 Docker 容器中常见的问题,但是我们可以使用 Docker 提供的命令行工具或者特定镜像来手动同步化时钟,从而处理这个问题。
2023-10-26 12:53:07
467
程序媛
Logstash
...ash中的系统时间不同步问题:原因、影响及解决方案 在大数据处理与日志分析的领域,Logstash作为Elastic Stack家族的重要成员,承担着数据收集、过滤与传输的关键任务。在实际做运维的时候,我们可能会碰到一个看着不起眼但实际上影响力超乎你想象的小问题——那就是Logstash和其他相关组件之间的系统时间没有同步好,就像一帮人各拿各的表,谁也不看谁的时间,这可真是个让人头疼的问题。本文将深入探讨这一现象,揭示其可能导致的各种认证或时间相关的错误,并通过实例代码和探讨性话术,帮助大家理解和解决这个问题。 1. 时间不同步引发的问题 问题描述 当Logstash与其他服务如Elasticsearch、Kibana或者Beats等的时间存在显著差异时,可能会导致一系列意想不到的问题: - 认证失败:许多API请求和安全认证机制都依赖于精确的时间戳来校验请求的有效性和防止重放攻击。时间不同步会导致这些验证逻辑失效。 - 事件排序混乱:在基于时间序列的数据分析中,Logstash接收、处理并输出的日志事件需要按照发生的时间顺序排列。时间不一致可能导致事件乱序,进而影响数据分析结果的准确性。 - 索引命名冲突:Elasticsearch使用时间戳作为索引命名的一部分,时间不同步可能导致新生成的索引名称与旧有索引重复,从而引发数据覆盖或其他存储问题。 2. 示例场景 时间不同步下的Logstash配置与问题复现 假设我们有一个简单的Logstash配置,用于从文件读取日志并发送至Elasticsearch: ruby input { file { path => "/var/log/app.log" start_position => "beginning" } } filter { date { match => ["timestamp", "ISO8601"] } } output { elasticsearch { hosts => ["localhost:9200"] index => "app-%{+YYYY.MM.dd}" } } 在这个例子中,如果Logstash服务器的时间比Elasticsearch服务器滞后了几个小时,那么根据Logstash处理的日志时间生成的索引名(例如app-2023.04.07)可能已经存在于Elasticsearch中,从而产生索引冲突。 3. 解决方案 保持系统时间同步 NTP服务 确保所有涉及的服务器均使用网络时间协议(Network Time Protocol, NTP)与权威时间源进行同步。在Linux系统中,可以通过以下命令安装并配置NTP服务: bash sudo apt-get install ntp sudo ntpdate pool.ntp.org 定期检查与纠正 对于关键业务系统,建议设置定时任务定期检查各节点时间偏差,并在必要时强制同步。此外,可以考虑在应用程序层面增加对时间差异的容忍度和容错机制。 容器环境 在Docker或Kubernetes环境中运行Logstash时,应确保容器内的时间与宿主机或集群其他组件保持同步。要让容器和宿主机的时间保持同步,一个实用的方法就是把宿主机里的那个叫/etc/localtime的文件“搬”到容器内部,这样就能实现时间共享啦,就像你和朋友共用一块手表看时间一样。 4. 总结与思考 面对Logstash与相关组件间系统时间不同步带来的挑战,我们需要充分认识到时间同步的重要性,并采取有效措施加以预防和修正。在日常运维这个活儿里,咱得把它纳入常规的“体检套餐”里,确保整个数据流处理这条生产线从头到尾都坚挺又顺畅,一步一个脚印,不出一丝差错。同时呢,随着技术的日益进步和实践经验日渐丰富,我们也要积极开动脑筋,探寻更高阶的时间同步策略,还有故障应急处理方案。这样一来,才能更好地应对那些复杂多变、充满挑战的生产环境需求嘛。
2023-11-18 11:07:16
305
草原牧歌
Golang
...ubernetes等容器编排系统中,大量采用Golang编写控制器和服务,有效利用并发特性提升集群资源调度效率。同时,许多大规模分布式系统如CockroachDB、Docker也选择Golang作为主要开发语言,充分利用其goroutine和channel的优势构建高可用、高性能的服务。 此外,学术界和工业界也在不断研究并发模型的新理论和最佳实践,如通过论文《Go Concurrency Patterns》(作者:Rob Pike)可以深入了解Go设计者对于并发编程的深度思考和实践经验分享。持续关注此类前沿资讯和研究成果,结合实际项目进行实践和应用,能够帮助开发者在Golang并发编程的世界里不断提升技术水平,应对日益复杂的软件工程挑战。
2023-02-26 18:14:07
405
林中小径
Golang
...统的功能,这对于构建容器镜像、处理配置文件等场景具有显著优势。 同时,随着Kubernetes和Docker等容器技术的发展,理解并掌握如何在分布式和容器化环境中安全高效地进行文件系统操作至关重要。比如,在Kubernetes中利用Volume进行持久化存储时,Go语言编写的控制器或operator如何正确管理Pod间共享的文件资源,避免并发写入导致的数据不一致问题。 此外,针对大规模数据处理场景,可研究Golang结合开源库如gofsutil来实现跨平台的文件系统挂载与管理,或者参考Netflix的开源项目如HDFS-Go客户端,了解如何在Go中实现与大数据文件系统(如Hadoop HDFS)的无缝集成。 最后,对于安全性要求极高的场景,不妨阅读相关安全研究论文及业界案例,探讨如何通过Go实现加密文件系统、访问控制列表等功能,确保敏感数据在存储和传输过程中的安全性。这些实时的、针对性的技术发展和实践应用将极大地丰富您对Go语言处理文件系统操作的理解,并帮助您在实际项目开发中做出更为明智和高效的决策。
2024-02-24 11:43:21
428
雪落无痕
Docker
Docker , Docker是一种开源的应用容器引擎,它通过将应用程序及其依赖打包到可移植的容器中,实现了软件的标准化部署和运行。在本文语境下,用户使用Docker来拉取、管理和运行官方提供的镜像,但在国内网络环境下遇到了访问不稳定的问题。 镜像(Image) , 在Docker环境下,镜像是一个轻量级、可执行的独立软件包,包含运行某个软件所需的所有内容,包括代码、运行时环境、系统工具库等。当用户执行docker pull命令拉取镜像时,实际上是下载这个包含了应用运行环境及应用本身的文件集合。 国内镜像源 , 由于网络原因,直接从国外的Docker Hub获取镜像可能会遇到速度慢或无法连接的问题。国内镜像源是针对这一问题提供的一种解决方案,它通常是托管在国内服务器上的Docker Registry服务,用于同步或缓存Docker Hub上的官方镜像。用户通过配置Docker以使用这些国内镜像源,可以提高镜像拉取的速度和稳定性。 daemon.json , 在Docker中,daemon.json是一个重要的配置文件,用于存储Docker守护进程的全局配置选项。当需要更改Docker的默认行为,如添加镜像加速器(registry mirror)、设置日志级别等时,就需要编辑这个文件。在本文中,作者通过修改daemon.json文件中的\ registry-mirrors\ 字段,指定使用国内的镜像源。 systemctl , systemctl是Systemd系统和服务管理器的一部分,用于管理系统级别的服务,例如启动、停止、重启服务以及查看服务状态等。在本文中,作者使用systemctl命令来重新加载Docker服务的配置并重启Docker服务,以便新的镜像源配置生效。
2024-03-06 16:10:51
401
程序媛
Redis
...源进行并发访问的一种同步机制。在一个分布式环境中,由于数据分布在多台服务器上,因此需要一种跨节点的锁机制来确保同一时间只有一个进程能执行特定操作。文中提到的Redis分布式锁即是利用Redis的原子操作特性,在多进程中协调对公共资源的访问控制。 Redis Cluster , Redis Cluster是Redis提供的原生集群解决方案,它将数据分散存储在多个节点上,提供数据分片(sharding)和高可用性。在解决文中提到的并发问题时,使用Redis Cluster可以有效避免单点故障,同时通过数据分区降低了多个Java进程竞争同一资源的可能性,从而提高了系统的并发处理能力和稳定性。 Spring Boot 2 , Spring Boot 2是一个流行的Java框架,用于简化新Spring应用的初始搭建以及开发过程。它包含了自动配置功能,使得开发者能够快速创建独立运行、生产级别的基于Spring框架的应用程序。在本文场景中,Spring Boot 2与Docker结合,为Java应用程序提供了便捷的部署和运行环境,并通过集成StringRedisTemplate类来方便地操作Redis。 Jedis , Jedis是一个Java编写的Redis客户端,用于连接Redis服务器并执行相关命令。在文章中,通过Spring Boot应用中的Jedis实例与Redis建立连接,并执行setnx命令以尝试获取分布式锁,体现了Jedis在实际项目开发中的重要角色。
2023-05-29 08:16:28
269
草原牧歌_t
转载文章
... pull 2、启动容器 run 3、进入容器 exec 1、镜像: docker hub官网搜索nginx 下载:docker pull nginx 查看下载情况:docker images 2、容器: 创建容器命令:docker run [-d 后台启动] [–name nginx01 起别名] [-p 3344:80 端口:协议] [镜像(包含版本)] (创建)启动容器实例:docker run -d --name nginx01 -p 3344:80 nginx 查看容器运行状况:docker ps 本机访问测试一下:curl localhost:3344 ■ 端口暴露 -p 宿主机端口:容器内部端口 浏览器输入: http://服务器ip地址:3344/ 3344 是暴露的端口 ----接下来: 进入(正在运行的)容器内部:docker exec -it nginx01 /bin/bash [root@iZwz9535z41cmgcpkm7i81Z /] docker exec -it nginx01 /bin/bashroot@d1a29e4791e3:/ whereis nginxnginx: /usr/sbin/nginx /usr/lib/nginx /etc/nginx /usr/share/nginxroot@d1a29e4791e3:/ cd /etc/nginxroot@d1a29e4791e3:/etc/nginx lsconf.d fastcgi_params mime.types modules nginx.conf scgi_params uwsgi_paramsroot@d1a29e4791e3:/etc/nginx ■ /bin/bash 是Linux的一种常用shell脚本,用于解释执行Linux命令,根据镜像支持的shell的不同,可以使用不同的的shell脚本。 容器,也是和虚拟机一样是虚拟技术呀,通过脚本执行/bin/bash实现,创建并进入容器内部docker ● 思考问题:每次改动nginx配置文件,都需要进入容器内部,十分麻烦: 要是可以在容器外部提供一个映射路径,达到在容器修改文件名,容器内部就可以自动修改?-v 数据卷技术! 二、部署tomcat docker run 可以不用pull,能自动下载 ctrl+c退出 docker pull tomcat:9.0 启动运行,应该加上版本号: docker run -d -p 3355:8080 --name tomcat01 tomcat:9.0 进入容器 docker exec -it tomcat01 /bin/bash ● 部署tomcat,发现问题: 1、linux命令少了 2、没有webapps 这是阿里云镜像的原因:默认使用最小镜像,所有不必要的都剔除了,保证最小可运行环境 可以通过拷贝的方式,解决没有webapps的问题: 在浏览器中输入:http://服务器ip地址:3355/ 进行访问 ● 思考问题:我们以后部署项目,如果每次都要进入容器很麻烦? 要是可以在容器外部提供一个映射路径,webapps,我们在外部放置项目,容器内部就可以自动修改?-v 数据卷技术! 三、部署es+kibana ● Elasticsearch 的问题: es 暴露的端口很多 es 十分耗内存 es 的数据一般需要放置到安全目录!挂载 1、问题1:es 十分耗内存 下载启动运行elastissearch 之后,Linux系统就变得特别卡 # 启动了 linux就卡住了docker stats# 查看 cpu的状态 #es 是十分耗内存的,1.xG# 1核2G(学生机)! # 查看 docker stats 2、问题2:es 需要暴露的端口很多 -p (下载)启动 elasticsearch$ docker run -d --name elasticsearch01 -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" elasticsearch:7.6.2 查看内存占用情况docker stats 先感觉stop一下docker stop ba18713ca536 3、es 十分耗内存的解决:增加内存的限制,修改配置文件 -e 环境配置修改 通过 -e 限制内存docker run -d --name elasticsearch02 -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" -e ES_JAVA_OPTS="-Xms64m -Xmx512m" elasticsearch:7.6.2 [root@iZwz9535z41cmgcpkm7i81Z /] curl localhost:9200/{"name" : "14329968b00f","cluster_name" : "docker-cluster","cluster_uuid" : "0iDu-G_KTo-4X8KORDj1XQ","version" : {"number" : "7.6.2","build_flavor" : "default","build_type" : "docker","build_hash" : "ef48eb35cf30adf4db14086e8aabd07ef6fb113f","build_date" : "2020-03-26T06:34:37.794943Z","build_snapshot" : false,"lucene_version" : "8.4.0","minimum_wire_compatibility_version" : "6.8.0","minimum_index_compatibility_version" : "6.0.0-beta1"},"tagline" : "You Know, for Search"} 4、思考:用kibana连接elasticsearch? 思考(kibana连接elasticsearch)网络如何连接过去 ☺ 参考来源: 狂神的B站视频《【狂神说Java】Docker最新超详细版教程通俗易懂》 https://www.bilibili.com/video/BV1og4y1q7M4 如果本文对你有帮助的话记得给一乐点个赞哦,感谢! 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_45630258/article/details/124785912。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-03-12 10:54:44
65
转载
转载文章
...删除相应内容。 随着容器技术越来越火热,各种大会上标杆企业分享容器化收益,带动其他还未实施容器的企业也在考虑实施容器化。不过真要在自己企业实践容器的时候,会认识到容器化不是一个简单工程,甚至会有一种茫然不知从何入手的感觉。 本文总结了通用的企业容器化实施线路图,主要针对企业有存量系统改造为容器,或者部分新开发的系统使用容器技术的场景。不包含企业系统从0开始全新构建的场景,这种场景相对简单。 容器实践路线图 企业着手实践容器的路线,建议从3个维度评估,然后根据评估结果落地实施。3个评估维度为:商业目标,技术选型,团队配合。 商业目标是重中之重,需要回答为何要容器化,这个也是牵引团队在容器实践路上不断前行的动力,是遇到问题是解决问题的方向指引,最重要的是让决策者认同商业目标,并能了解到支持商业目标的技术原理,上下目标对齐才好办事。 商业目标确定之后,需要确定容器相关的技术选型,容器是一种轻量化的虚拟化技术,与传统虚拟机比较有优点也有缺点,要找出这些差异点识别出对基础设施与应用的影响,提前识别风险并采取应对措施。 技术选型明确之后,在公司或部门内部推广与评审,让开发人员、架构师、测试人员、运维人员相关人员与团队理解与认同方案,听取他们意见,他们是直接使用容器的客户,不要让他们有抱怨。 最后是落地策略,一般是选取一些辅助业务先试点,在实践过程中不断总结经验。 商业目标 容器技术是以应用为中心的轻量级虚拟化技术,而传统的Xen与KVM是以资源为中心的虚拟化技术,这是两者的本质差异。以应用为中心是容器技术演进的指导原则,正是在这个原则指导下,容器技术相对于传统虚拟化有几个特点:打包既部署、镜像分层、应用资源调度。 打包即部署:打包即部署是指在容器镜像制作过程包含了传统软件包部署的过程(安装依赖的操作系统库或工具、创建用户、创建运行目录、解压、设置文件权限等等),这么做的好处是把应用及其依赖封装到了一个相对封闭的环境,减少了应用对外部环境的依赖,增强了应用在各种不同环境下的行为一致性,同时也减少了应用部署时间。 镜像分层:容器镜像包是分层结构,同一个主机上的镜像层是可以在多个容器之间共享的,这个机制可以极大减少镜像更新时候拉取镜像包的时间,通常应用程序更新升级都只是更新业务层(如Java程序的jar包),而镜像中的操作系统Lib层、运行时(如Jre)层等文件不会频繁更新。因此新版本镜像实质有变化的只有很小的一部分,在更新升级时候也只会从镜像仓库拉取很小的文件,所以速度很快。 应用资源调度:资源(计算/存储/网络)都是以应用为中心的,中心体现在资源分配是按照应用粒度分配资源、资源随应用迁移。 基于上述容器技术特点,可以推导出容器技术的3大使用场景:CI/CD、提升资源利用率、弹性伸缩。这3个使用场景自然推导出通用的商业层面收益:CI/CD提升研发效率、提升资源利用率降低成本、按需弹性伸缩在体验与成本之间达成平衡。 当然,除了商业目标之外,可能还有其他一些考虑因素,如基于容器技术实现计算任务调度平台、保持团队技术先进性等。 CI/CD提升研发效率 为什么容器技术适合CI/CD CI/CD是DevOps的关键组成部分,DevOps是一套软件工程的流程,用于持续提升软件开发效率与软件交付质量。DevOps流程来源于制造业的精益生产理念,在这个领域的领头羊是丰田公司,《丰田套路》这本书总结丰田公司如何通过PDCA(Plan-Do-Check-Act)方法实施持续改进。PDCA通常也称为PDCA循环,PDCA实施过程简要描述为:确定目标状态、分析当前状态、找出与目标状态的差距、制定实施计划、实施并总结、开始下一个PDCA过程。 DevOps基本也是这么一个PDCA流程循环,很容易认知到PDCA过程中效率是关键,同一时间段内,实施更多数量的PDCA过程,收益越高。在软件开发领域的DevOps流程中,各种等待(等待编译、等待打包、等待部署等)、各种中断(部署失败、机器故障)是影响DevOps流程效率的重要因素。 容器技术出来之后,将容器技术应用到DevOps场景下,可以从技术手段消除DevOps流程中的部分等待与中断,从而大幅度提升DevOps流程中CI/CD的效率。 容器的OCI标准定义了容器镜像规范,容器镜像包与传统的压缩包(zip/tgz等)相比有两个关键区别点:1)分层存储;2)打包即部署。 分层存储可以极大减少镜像更新时候拉取镜像包的时间,通常应用程序更新升级都只是更新业务层(如Java程序的jar包),而镜像中的操作系统Lib层、运行时(如Jre)层等文件不会频繁更新。因此新版本镜像实质有变化的只有很小的一部分,在更新升级时候也只会从镜像仓库拉取很小的文件,所以速度很快。 打包即部署是指在容器镜像制作过程包含了传统软件包部署的过程(安装依赖的操作系统库或工具、创建用户、创建运行目录、解压、设置文件权限等等),这么做的好处是把应用及其依赖封装到了一个相对封闭的环境,减少了应用对外部环境的依赖,增强了应用在各种不同环境下的行为一致性,同时也减少了应用部署时间。 基于容器镜像的这些优势,容器镜像用到CI/CD场景下,可以减少CI/CD过程中的等待时间,减少因环境差异而导致的部署中断,从而提升CI/CD的效率,提升整体研发效率。 CI/CD的关键诉求与挑战 快 开发人员本地开发调试完成后,提交代码,执行构建与部署,等待部署完成后验证功能。这个等待的过程尽可能短,否则开发人员工作容易被打断,造成后果就是效率降低。如果提交代码后几秒钟就能够完成部署,那么开发人员几乎不用等待,工作也不会被打断;如果需要好几分钟或十几分钟,那么可以想象,这十几分钟就是浪费了,这时候很容易做点别的事情,那么思路又被打断了。 所以构建CI/CD环境时候,快是第一个需要考虑的因素。要达到快,除了有足够的机器资源免除排队等待,引入并行编译技术也是常用做法,如Maven3支持多核并行构建。 自定义流程 不同行业存在不同的行业规范、监管要求,各个企业有一套内部质量规范,这些要求都对软件交付流程有定制需求,如要求使用商用的代码扫描工具做安全扫描,如构建结果与企业内部通信系统对接发送消息。 在团队协同方面,不同的公司,对DevOps流程在不同团队之间分工有差异,典型的有开发者负责代码编写构建出构建物(如jar包),而部署模板、配置由运维人员负责;有的企业开发人员负责构建并部署到测试环境;有的企业开发人员直接可以部署到生产环境。这些不同的场景,对CI/CD的流程、权限管控都有定制需求。 提升资源利用率 OCI标准包含容器镜像标准与容器运行时标准两部分,容器运行时标准聚焦在定义如何将镜像包从镜像仓库拉取到本地并更新、如何隔离运行时资源这些方面。得益于分层存储与打包即部署的特性,容器镜像从到镜像仓库拉取到本地运行速度非常快(通常小于30秒,依赖镜像本身大小等因素),基于此可以实现按需分配容器运行时资源(cpu与内存),并限定单个容器资源用量;然后根据容器进程资源使用率设定弹性伸缩规则,实现自动的弹性伸缩。 这种方式相对于传统的按峰值配置资源方式,可以提升资源利用率。 按需弹性伸缩在体验与成本之间达成平衡 联动弹性伸缩 应用运行到容器,按需分配资源之后,理想情况下,Kubernetes的池子里没有空闲的资源。这时候扩容应用实例数,新扩容的实例会因资源不足调度失败。这时候需要资源池能自动扩容,加入新的虚拟机,调度新扩容的应用。 由于应用对资源的配比与Flavor有要求,因此新加入的虚拟机,应当是与应用所需要的资源配比与Flavor一致的。缩容也是类似。 弹性伸缩还有一个诉求点是“平滑”,对业务做到不感知,也称为“优雅”扩容/缩容。 请求风暴 上面提到的弹性伸缩一般是有计划或缓慢增压的场景,存在另外一种无法预期的请求风暴场景,这种场景的特征是无法预测、突然请求量增大数倍或数十倍、持续时间短。典型的例子如行情交易系统,当行情突变的时候,用户访问量徒增,持续几十分钟或一个小时。 这种场景的弹性诉求,要求短时间内能将资源池扩大数倍,关键是速度要快(秒级),否则会来不及扩容,系统已经被冲垮(如果无限流的话)。 目前基于 Virtual Kubelet 与云厂家的 Serverless 容器,理论上可以提供应对请求风暴的方案。不过在具体实施时候,需要考虑传统托管式Kubernetes容器管理平台与Serverless容器之间互通的问题,需要基于具体厂家提供的能力来评估。 基于容器技术实现计算调度平台 计算(大数据/AI训练等)场景的特征是短时间内需要大量算力,算完即释放。容器的环境一致性以及调度便利性适合这种场景。 技术选型 容器技术是属于基础设施范围,但是与传统虚拟化技术(Xen/KVM)比较,容器技术是应用虚拟化,不是纯粹的资源虚拟化,与传统虚拟化存在差异。在容器技术选型时候,需要结合当前团队在应用管理与资源管理的现状,对照容器技术与虚拟化技术的差异,选择最合适的容器技术栈。 什么是容器技术 (1)容器是一种轻量化的应用虚拟化技术。 在讨论具体的容器技术栈的时候,先介绍目前几种常用的应用虚拟化技术,当前有3种主流的应用虚拟化技术: LXC,MicroVM,UniKernel(LibOS)。 LXC: Linux Container,通过 Linux的 namespace/cgroups/chroot 等技术隔离进程资源,目前应用最广的docker就是基于LXC实现应用虚拟化的。 MicroVM: MicroVM 介于 传统的VM 与 LXC之间,隔离性比LXC好,但是比传统的VM要轻量,轻量体现在体积小(几M到几十M)、启动快(小于1s)。 AWS Firecracker 就是一种MicroVM的实现,用于AWS的Serverless计算领域,Serverless要求启动快,租户之间隔离性好。 UniKernel: 是一种专用的(特定编程语言技术栈专用)、单地址空间、使用 library OS 构建出来的镜像。UniKernel要解决的问题是减少应用软件的技术栈层次,现代软件层次太多导致越来越臃肿:硬件+HostOS+虚拟化模拟+GuestOS+APP。UniKernel目标是:硬件+HostOS+虚拟化模拟+APP-with-libos。 三种技术对比表: 开销 体积 启动速度 隔离/安全 生态 LXC 低(几乎为0) 小 快(等同进程启动) 差(内核共享) 好 MicroVM 高 大 慢(小于1s) 好 中(Kata项目) UniKernel 中 中 中 好 差 根据上述对比来看,LXC是应用虚拟化首选的技术,如果LXC无法满足隔离性要,则可以考虑MicroVM这种技术。当前社区已经在着手融合LXC与MicroVM这两种技术,从应用打包/发布调度/运行层面统一规范,Kubernetes集成Kata支持混合应用调度特性可以了解一下。 UniKernel 在应用生态方面相对比较落后,目前在追赶中,目前通过 linuxkit 工具可以在UniKernel应用镜像中使用docker镜像。这种方式笔者还未验证过,另外docker镜像运行起来之后,如何监控目前还未知。 从上述三种应用虚拟化技术对比,可以得出结论: (2)容器技术与传统虚拟化技术不断融合中。 再从规范视角来看容器技术,可以将容器技术定义为: (3)容器=OCI+CRI+辅助工具。 OCI规范包含两部分,镜像规范与运行时规范。简要的说,要实现一个OCI的规范,需要能够下载镜像并解压镜像到文件系统上组成成一个文件目录结构,运行时工具能够理解这个目录结构并基于此目录结构管理(创建/启动/停止/删除)进程。 容器(container)的技术构成就是实现OCI规范的技术集合。 对于不同的操作系统(Linux/Windows),OCI规范的实现技术不同,当前docker的实现,支持Windows与Linux与MacOS操作系统。当前使用最广的是Linux系统,OCI的实现,在Linux上组成容器的主要技术: chroot: 通过分层文件系统堆叠出容器进程的rootfs,然后通过chroot设置容器进程的根文件系统为堆叠出的rootfs。 cgroups: 通过cgroups技术隔离容器进程的cpu/内存资源。 namesapce: 通过pid, uts, mount, network, user namesapce 分别隔离容器进程的进程ID,时间,文件系统挂载,网络,用户资源。 网络虚拟化: 容器进程被放置到独立的网络命名空间,通过Linux网络虚拟化veth, macvlan, bridge等技术连接主机网络与容器虚拟网络。 存储驱动: 本地文件系统,使用容器镜像分层文件堆叠的各种实现驱动,当前推荐的是overlay2。 广义的容器还包含容器编排,即当下很火热的Kubernetes。Kubernetes为了把控容器调度的生态,发布了CRI规范,通过CRI规范解耦Kubelet与容器,只要实现了CRI接口,都可以与Kubelet交互,从而被Kubernetes调度。OCI规范的容器实现与CRI标准接口对接的实现是CRI-O。 辅助工具用户构建镜像,验证镜像签名,管理存储卷等。 容器定义 容器是一种轻量化的应用虚拟化技术。 容器=OCI+CRI+辅助工具。 容器技术与传统虚拟化技术不断融合中。 什么是容器编排与调度 选择了应用虚拟化技术之后,还需要应用调度编排,当前Kubernetes是容器领域内编排的事实标准,不管使用何种应用虚拟化技术,都已经纳入到了Kubernetes治理框架中。 Kubernetes 通过 CRI 接口规范,将应用编排与应用虚拟化实现解耦:不管使用何种应用虚拟化技术(LXC, MicroVM, LibOS),都能够通过Kubernetes统一编排。 当前使用最多的是docker,其次是cri-o。docker与crio结合kata-runtime都能够支持多种应用虚拟化技术混合编排的场景,如LXC与MicroVM混合编排。 docker(now): Moby 公司贡献的 docker 相关部件,当前主流使用的模式。 docker(daemon) 提供对外访问的API与CLI(docker client) containerd 提供与 kubelet 对接的 CRI 接口实现 shim负责将Pod桥接到Host namespace。 cri-o: 由 RedHat/Intel/SUSE/IBM/Hyper 公司贡献的实现了CRI接口的符合OCI规范的运行时,当前包括 runc 与 kata-runtime ,也就是说使用 cir-o 可以同时运行LXC容器与MicroVM容器,具体在Kata介绍中有详细说明。 CRI-O: 实现了CRI接口的进程,与 kubelet 交互 crictl: 类似 docker 的命令行工具 conmon: Pod监控进程 other cri runtimes: 其他的一些cri实现,目前没有大规模应用到生产环境。 容器与传统虚拟化差异 容器(container)的技术构成 前面主要讲到的是容器与编排,包括CRI接口的各种实现,我们把容器领域的规范归纳为南向与北向两部分,CRI属于北向接口规范,对接编排系统,OCI就属于南向接口规范,实现应用虚拟化。 简单来讲,可以这么定义容器: 容器(container) ~= 应用打包(build) + 应用分发(ship) + 应用运行/资源隔离(run)。 build-ship-run 的内容都被定义到了OCI规范中,因此也可以这么定义容器: 容器(container) == OCI规范 OCI规范包含两部分,镜像规范与运行时规范。简要的说,要实现一个OCI的规范,需要能够下载镜像并解压镜像到文件系统上组成成一个文件目录结构,运行时工具能够理解这个目录结构并基于此目录结构管理(创建/启动/停止/删除)进程。 容器(container)的技术构成就是实现OCI规范的技术集合。 对于不同的操作系统(Linux/Windows),OCI规范的实现技术不同,当前docker的实现,支持Windows与Linux与MacOS操作系统。当前使用最广的是Linux系统,OCI的实现,在Linux上组成容器的主要技术: chroot: 通过分层文件系统堆叠出容器进程的rootfs,然后通过chroot设置容器进程的根文件系统为堆叠出的rootfs。 cgroups: 通过cgroups技术隔离容器进程的cpu/内存资源。 namesapce: 通过pid, uts, mount, network, user namesapce 分别隔离容器进程的进程ID,时间,文件系统挂载,网络,用户资源。 网络虚拟化: 容器进程被放置到独立的网络命名空间,通过Linux网络虚拟化veth, macvlan, bridge等技术连接主机网络与容器虚拟网络。 存储驱动: 本地文件系统,使用容器镜像分层文件堆叠的各种实现驱动,当前推荐的是overlay2。 广义的容器还包含容器编排,即当下很火热的Kubernetes。Kubernetes为了把控容器调度的生态,发布了CRI规范,通过CRI规范解耦Kubelet与容器,只要实现了CRI接口,都可以与Kubelet交互,从而被Kubernetes调度。OCI规范的容器实现与CRI标准接口对接的实现是CRI-O。 容器与虚拟机差异对比 容器与虚拟机的差异可以总结为2点:应用打包与分发的差异,应用资源隔离的差异。当然,导致这两点差异的根基是容器是以应用为中心来设计的,而虚拟化是以资源为中心来设计的,本文对比容器与虚拟机的差异,更多的是站在应用视角来对比。 从3个方面对比差异:资源隔离,应用打包与分发,延伸的日志/监控/DFX差异。 1.资源隔离 隔离机制差异 容器 虚拟化 mem/cpu cgroup, 使用时候设定 require 与 limit 值 QEMU, KVM network Linux网络虚拟化技术(veth,tap,bridge,macvlan,ipvlan), 跨虚拟机或出公网访问:SNAT/DNAT, service转发:iptables/ipvs, SR-IOV Linux网络虚拟化技术(veth,tap,bridge,macvlan,ipvlan), QEMU, SR-IOV storage 本地存储: 容器存储驱动 本地存储:virtio-blk 差异引入问题与实践建议 应用程序未适配 cgroup 的内存隔离导致问题: 典型的是 JVM 虚拟机,在 JVM 启动时候会根据系统内存自动设置 MaxHeapSize 值,通常是系统内存的1/4,但是 JVM 并未考虑 cgroup 场景,读系统内存时候任然读取主机的内存来设置 MaxHeapSize,这样会导致内存超过 cgroup 限制从而导致进程被 kill 。问题详细阐述与解决建议参考Java inside docker: What you must know to not FAIL。 多次网络虚拟化问题: 如果在虚拟机内使用容器,会多一层网络虚拟化,并加入了SNAT/DNAT技术, iptables/ipvs技术,对网络吞吐量与时延都有影响(具体依赖容器网络方案),对问题定位复杂度变高,同时还需要注意网络内核参数调优。 典型的网络调优参数有:转发表大小 /proc/sys/net/netfilter/nf_conntrack_max 使用iptables 作为service转发实现的时候,在转发规则较多的时候,iptables更新由于需要全量更新导致非常耗时,建议使用ipvs。详细参考[华为云在 K8S 大规模场景下的 Service 性能优化实践](https://zhuanlan.zhihu.com/p/37230013)。 容器IP地址频繁变化不固定,周边系统需要协调适配,包括基于IP地址的白名单或防火墙控制策略需要调整,CMDB记录的应用IP地址需要适配动态IP或者使用服务名替代IP地址。 存储驱动带来的性能损耗: 容器本地文件系统是通过联合文件系统方式堆叠出来的,当前主推与默认提供的是overlay2驱动,这种模式应用写本地文件系统文件或修改已有文件,使用Copy-On-Write方式,也就是会先拷贝源文件到可写层然后修改,如果这种操作非常频繁,建议使用 volume 方式。 2.应用打包与分发 应用打包/分发/调度差异 容器 虚拟化 打包 打包既部署 一般不会把应用程序与虚拟机打包在一起,通过部署系统部署应用 分发 使用镜像仓库存储与分发 使用文件存储 调度运行 使用K8S亲和/反亲和调度策略 使用部署系统的调度能力 差异引入问题与实践建议 部署提前到构建阶段,应用需要支持动态配置与静态程序分离;如果在传统部署脚本中依赖外部动态配置,这部分需要做一些调整。 打包格式发生变化,制作容器镜像需要注意安全/效率因素,可参考Dockerfile最佳实践 容器镜像存储与分发是按layer来组织的,镜像在传输过程中放篡改的方式是传统软件包有差异。 3.监控/日志/DFX 差异 容器 虚拟化 监控 cpu/mem的资源上限是cgroup定义的;containerd/shim/docker-daemon等进程的监控 传统进程监控 日志采集 stdout/stderr日志采集方式变化;日志持久化需要挂载到volume;进程会被随机调度到其他节点导致日志需要实时采集否则分散很难定位 传统日志采集 问题定位 进程down之后自动拉起会导致问题定位现场丢失;无法停止进程来定位问题因为停止即删除实例 传统问题定位手段 差异引入问题实践与建议 使用成熟的监控工具,运行在docker中的应用使用cadvisor+prometheus实现采集与警报,cadvisor中预置了常用的监控指标项 对于docker管理进程(containerd/shim/docker-daemon)也需要一并监控 使用成熟的日志采集工具,如果已有日志采集Agent,则可以考虑将日志文件挂载到volume后由Agent采集;需要注意的是stderr/stdout输出也要一并采集 如果希望容器内应用进程退出后保留现场定位问题,则可以将Pod的restartPolicy设置为never,进程退出后进程文件都还保留着(/var/lib/docker/containers)。但是这么做的话需要进程没有及时恢复,会影响业务,需要自己实现进程重拉起。 团队配合 与周边的开发团队、架构团队、测试团队、运维团队评审并交流方案,与周边团队达成一致。 落地策略与注意事项 逐步演进过程中网络互通 根据当前已经存在的基础实施情况,选择容器化落地策略。通常使用逐步演进的方式,由于容器化引入了独立的网络namespace导致容器与传统虚拟机进程网络隔离,逐步演进过程中如何打通隔离的网络是最大的挑战。 分两种场景讨论: 不同服务集群之间使用VIP模式互通: 这种模式相对简单,基于VIP做灰度发布。 不同服务集群之间使用微服务点对点模式互通(SpringCloud/ServiceComb/Dubbo都是这一类): 这种模式相对复杂,在逐步容器化过程中,要求容器网络与传统虚拟机网络能够互通(难点是在虚拟机进程内能够直接访问到容器网络的IP地址),当前解决这个问题有几种方法。 自建Kubernetes场景,可使用开源的kube-router,kube-router 使用BGP协议实现容器网络与传统虚拟机网络之间互通,要求网络交换机支持BGP协议。 使用云厂商托管Kubernetes场景,选择云厂商提供的VPC-Router互通的网络插件,如阿里云的Terway网络插件, 华为云的Underlay网络模式。 选择物理机还是虚拟机 选择物理机运行容器还是虚拟机运行容器,需要结合基础设施与业务隔离性要求综合考虑。分两种场景:自建IDC、租用公有云。 自建IDC: 理想情况是使用物理机组成一个大集群,根据业务诉求,对资源保障与安全性要求高的应用,使用MicorVM方式隔离;普通应用使用LXC方式隔离。所有物理机在一个大集群内,方便削峰填谷提升资源利用率。 租用公有云:当前公有云厂家提供的裸金属服务价格较贵且只能包周期,使用裸金属性价比并不高,使用虚拟机更合适。 集群规模与划分 选择集群时候,是多个应用共用一个大集群,还是按应用分组分成多个小集群呢?我们把节点规模数量>=1000的定义为大集群,节点数<1000的定义为小集群。 大集群的优点是资源池共享容器,方便资源调度(削峰填谷);缺点是随着节点数量与负载数量的增多,会引入管理性能问题(需要量化): DNS 解析表变大,增加/删除 Service 或 增加/删除 Endpoint 导致DNS表刷新慢 K8S Service 转发表变大,导致工作负载增加/删除刷新iptables/ipvs记录变慢 etcd 存储空间变大,如果加上ConfigMap,可能导致 etcd 访问时延增加 小集群的优点是不会有管理性能问题,缺点是会导致资源碎片化,不容易共享。共享分两种情况: 应用之间削峰填谷:目前无法实现 计算任务与应用之间削峰填谷:由于计算任务是短时任务,可以通过上层的任务调度软件,在多个集群之间分发计算任务,从而达到集群之间资源共享的目的。 选择集群规模的时候,可以参考上述分析,结合实际情况选择适合的集群划分。 Helm? Helm是为了解决K8S管理对象散碎的问题,在K8S中并没有"应用"的概念,只有一个个散的对象(Deployment, ConfigMap, Service, etc),而一个"应用"是多个对象组合起来的,且这些对象之间还可能存在一定的版本配套关系。 Helm 通过将K8S多个对象打包为一个包并标注版本号形成一个"应用",通过 Helm 管理进程部署/升级这个"应用"。这种方式解决了一些问题(应用分发更方便)同时也引入了一些问题(引入Helm增加应用发布/管理复杂度、在K8S修改了对象后如何同步到Helm)。对于是否需要使用Helm,建议如下: 在自运维模式下不使用Helm: 自运维模式下,很多场景是开发团队交付一个运行包,运维团队负责部署与配置下发,内部通过兼容性或软件包与配置版本配套清单、管理软件包与配置的配套关系。 在交付软件包模式下使用Helm: 交付软件包模式下,Helm 这种把散碎组件组装为一个应用的模式比较适合,使用Helm实现软件包分发/部署/升级场比较简单。 Reference DOCKER vs LXC vs VIRTUAL MACHINES Cgroup与LXC简介 Introducing Container Runtime Interface (CRI) in Kubernetes frakti rkt appc-spec OCI 和 runc:容器标准化和 docker Linux 容器技术史话:从 chroot 到未来 Linux Namespace和Cgroup Java inside docker: What you must know to not FAIL QEMU,KVM及QEMU-KVM介绍 kvm libvirt qemu实践系列(一)-kvm介绍 KVM 介绍(4):I/O 设备直接分配和 SR-IOV [KVM PCI/PCIe Pass-Through SR-IOV] prometheus-book 到底什么是Unikernel? The Rise and Fall of the Operating System The Design and Implementation of the Anykernel and Rump Kernels UniKernel Unikernel:从不入门到入门 OSv 京东如何打造K8s全球最大集群支撑万亿电商交易 Cloud Native App Hub 更多云最佳实践 https://best.practices.cloud 本篇文章为转载内容。原文链接:https://blog.csdn.net/sinat_33155975/article/details/118013855。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-09-17 15:03:28
225
转载
Docker
Docker , Docker是一种开源的应用容器引擎,它通过容器化技术将应用程序及其依赖环境打包成独立、可移植的软件单元。在Docker中,每个容器都是一个轻量级、隔离的操作系统层,可以在任何支持Docker的主机上运行,确保了应用在不同环境下的一致性和可移植性。 Volumes , 在Docker中,Volumes是用于持久化存储的一种机制,允许将宿主机的文件系统与容器内部的文件系统进行挂载映射。即使容器停止或重新创建,通过Volumes机制绑定的数据也能得到持久保存,实现容器内外数据的共享和持久化存储。 Dockerfile , Dockerfile是一个文本文件,包含了一系列用于构建Docker镜像的指令集合。开发人员可以通过编写Dockerfile来定义应用程序如何被封装到Docker容器中,包括所需的基础镜像、安装依赖、配置环境变量以及复制本地文件到容器内等操作步骤。通过执行docker build命令基于Dockerfile生成的镜像,可以保证每次部署时,容器内的应用程序环境一致且可重复构建。
2023-12-30 15:13:37
472
编程狂人
Docker
在利用Docker的期间,数据路径是至关重要的。Docker是利用映像的方式构建容器,容器中的数据也需要存储在本地,因此Docker的数据管控是依赖于存储卷(Volume)和存储卷容器(Volume Container)达成的。 存储卷是Docker提供的一种方式,可以将本地宿主机的目录及文件装载到容器内部。存储卷可以保证容器中的数据持久保存,且容器的数据可以在不同的容器之间分享。比如,下面的命令将本地目录 /data 装载到容器内部的 /app 目录: docker run -v /data:/app image_name 利用这种方式,容器中的数据发生变化时,本地宿主机的数据也会随之更新,也可以通过修改本地宿主机上的文件来修改容器中的文件。 存储卷容器是一种特殊的容器,用于管理存储卷。存储卷容器与存储卷的关系就像是一个储藏室和一个存储空间的关系。存储卷容器负责构建存储卷和管理存储卷的生命周期,而其他容器可以通过装载存储卷容器来利用存储卷。比如,下面的命令构建一个名为 my_data 的存储卷容器: docker create -v /app --name my_data busybox 利用这种方式,可以通过装载 my_data 存储卷容器来利用存储卷,比如: docker run --volumes-from my_data image_name 在利用存储卷的期间,还有一些需要注意的细节。首先,不同的容器中装载的存储卷是相互隔离的,因此不同的容器不能利用相同的目录装载存储卷;其次,利用 -v 参数构建容器时,如果本地目录不存在,则会自动构建;最后,存储卷的更新和删除需要手动执行,否则存储卷和容器中的数据将一直存在。
2023-10-29 12:32:53
504
软件工程师
Docker
Docker是一种很普遍的应用容器化平台。它允许程序员在容器中封装,部署和执行各种应用。在Docker中,映像是创建容器的基础。映像是一个不可写的模板文件,它定义如何创建容器。它涵盖应用所需的所有文件和设置,例如源文件,依赖项,环境参数等。映像有标记,标记是对映像版本的引用。 在Docker中,更改映像的标记是一种常见操作。有时您需要为已有的映像打新的标记。这可以用于将映像标记为不同的版本,使其更容易区分和管理。以下是如何在Docker中更改映像标记的示例: 列出您现有的映像 docker images 将映像标记为新标记 docker tag old_image_tag new_image_tag 列出你的映像,观察新的标签是否被添加 docker images 在此示例中,您需要首先列出已有的映像。这将帮助您确定要更改的映像的名称和标记。接下来,您需要执行Docker tag命令,并将所需的标记指定为新标记。这会在映像名称下添加一个新标记。最后,您需要再次列出您的映像,并确保新的标记已添加成功。 更改Docker映像标记是一个很简单的过程。这使得容器的版本控制和管理变得非常容易。您也可以使用标记来跟踪和管理您的容器和应用。
2023-03-17 16:21:20
311
编程狂人
Tomcat
...va程序时的文件权限问题及其解决方案后,进一步探究操作系统层面的安全机制和权限管理策略具有重要意义。近期,随着Apache Tomcat 10.x版本对Jakarta EE 9的支持升级,更多用户开始关注其在生产环境中的安全性配置。尤其在容器化、云原生服务普及的趋势下,如何结合Docker、Kubernetes等工具进行细粒度的权限控制成为热点话题。 例如,2022年某知名云计算服务商发布的一篇技术博客中,详细阐述了如何在Kubernetes集群中部署Tomcat应用,并通过安全上下文约束(Pod Security Policies)来严格管控容器内部文件系统的访问权限,防止因误操作或其他安全事件导致的数据泄露或服务中断。 同时,对于企业级用户来说,深入理解Unix/Linux文件系统ACL(Access Control List)扩展机制也是必不可少的。ACL允许更灵活、详细的权限分配,超越传统的用户、组、其他三类权限设定,能够实现针对特定用户的精细化权限控制,这对于维护复杂的企业级Java应用至关重要。 另外,持续跟进Apache Tomcat官方发布的安全公告与补丁更新,了解并及时修复可能影响到文件权限管理的相关漏洞,是保障服务器稳定运行的重要一环。在此基础上,结合最佳实践,如遵循最小权限原则设置文件权限,可以有效降低潜在的安全风险,确保Java应用程序在Tomcat上的安全、高效运行。
2023-10-23 09:02:38
243
岁月如歌-t
ZooKeeper
...或者,你也可以直接用Docker,几下敲敲代码就搞定了,超级方便! bash docker run -d --name zookeeper -p 2181:2181 zookeeper 这样我们就有了一个本地的ZooKeeper服务。接下来,我们可以开始编写客户端代码了。 3. 设置数据 3.1 使用Java API设置数据 让我们先从Java API开始。想象一下,我们要在系统里建个新家,就叫它/myapp/config吧。然后呢,我们往这个新家里放点儿配置文件,好让它知道该怎么干活。下面是一个简单的代码示例: java import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.CreateMode; import org.apache.zookeeper.ZooDefs.Ids; public class ZookeeperExample { public static void main(String[] args) throws Exception { // 创建ZooKeeper实例 ZooKeeper zk = new ZooKeeper("localhost:2181", 5000, watchedEvent -> {}); // 设置节点数据 byte[] data = "some config data".getBytes(); String path = "/myapp/config"; // 创建临时节点 String createdPath = zk.create(path, data, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); System.out.println("Created node: " + createdPath); // 关闭连接 zk.close(); } } 在这个例子中,我们首先创建了一个ZooKeeper实例,并指定了连接超时时间。然后呢,我们就用create这个魔法命令变出了一个持久节点,还往里面塞了一些配置信息。最后,我们关闭了连接。 3.2 使用Python API设置数据 如果你更喜欢Python,也可以使用Python客户端库kazoo来操作ZooKeeper。下面是一个简单的示例: python from kazoo.client import KazooClient zk = KazooClient(hosts='127.0.0.1:2181') zk.start() 设置节点数据 zk.create('/myapp/config', b'some config data', makepath=True) print("Node created") zk.stop() 这段代码同样创建了一个持久节点,并写入了一些配置信息。这里我们使用了makepath=True参数来自动创建父节点。 4. 获取数据 4.1 使用Java API获取数据 接下来,我们来看看如何获取节点的数据。假设我们要读取刚刚创建的那个节点中的配置信息,可以这样做: java import org.apache.zookeeper.ZooKeeper; public class ZookeeperExample { public static void main(String[] args) throws Exception { // 创建ZooKeeper实例 ZooKeeper zk = new ZooKeeper("localhost:2181", 5000, watchedEvent -> {}); // 获取节点数据 byte[] data = zk.getData("/myapp/config", false, null); System.out.println("Data: " + new String(data)); // 关闭连接 zk.close(); } } 在这个例子中,我们使用getData方法读取了节点/myapp/config中的数据,并将其转换为字符串打印出来。 4.2 使用Python API获取数据 同样地,使用Python的kazoo库也可以轻松完成这一操作: python from kazoo.client import KazooClient zk = KazooClient(hosts='127.0.0.1:2181') zk.start() 获取节点数据 data, stat = zk.get('/myapp/config') print("Node data: " + data.decode()) zk.stop() 这里我们使用了get方法来获取节点数据,同时返回了节点的状态信息。 5. 总结与思考 通过上面的代码示例,我们可以看到,无论是使用Java还是Python,设置和获取ZooKeeper节点数据的过程都非常直观。但实际上,在真实使用中可能会碰到一些麻烦,比如说网络卡顿啊,或者有些节点突然不见了之类的。这就得在开发时不断地调整和改进,确保系统又稳又靠谱。 希望今天的分享对你有所帮助!如果你有任何问题或建议,欢迎随时交流。
2025-01-25 15:58:48
45
桃李春风一杯酒
Etcd
...信息。它被广泛应用于容器编排工具 Kubernetes 中,以提供服务发现和配置管理功能。不过呢,虽然 Etcd 这家伙性能强大、稳定性杠杠的,但偶尔也会受点外部因素的窝囊气,比如突如其来的电源故障啥的,就可能让它闹点小情绪。本文将深入探讨这种问题,并提供有效的解决方案。 二、Etcd 数据库结构 Etcd 的数据库是一个基于 gRPC 的分布式 key-value 存储系统。它就像一个大家庭,由一群实力相当的兄弟服务器组成,每台服务器都各自保管着一部分数据,而且个个都能独立完成读取和写入这些数据的任务,谁也不用依赖谁。如果有一个节点突然罢工了,其他节点就会立马顶上,接手它的工作任务,这样就能确保整个系统的稳定运行和数据的一致性,就像一个团队中有人请假了,其他人会立刻补位,保证工作顺利进行一样。 三、电源故障对 Etcd 数据库的影响 1. 数据丢失 电源故障可能会导致数据无法保存到磁盘上,从而使 Etcd 丢失部分或全部数据。 2. 系统不稳定 当多个节点同时出现电源故障时,可能会导致整个 Etcd 系统变得不稳定,甚至无法正常运行。 四、解决方法 1. 数据备份 定期对 Etcd 数据进行备份可以帮助我们在遇到电源故障时快速恢复数据。我们可以使用 etcdctl 工具来创建和导出数据备份。 示例代码: 创建备份文件 etcdctl backup save mybackup.etcd 导出备份文件 etcdctl backup export mybackup.etcd 2. 使用高可用架构 我们可以通过设置冗余节点和负载均衡器来提高 Etcd 系统的高可用性。当一个节点出现故障时,其他节点可以接替其工作,从而避免服务中断。 3. 增加电源冗余 为了防止电源故障,我们可以增加电源冗余,例如使用 UPS 或备用发电机。 五、结论 虽然电源故障可能会对 Etcd 数据库造成严重影响,但我们可以通过数据备份、使用高可用架构和增加电源冗余等方式来降低这种风险。如果我们采取适当的预防措施,就能妥妥地保护那些至关重要的数据,并且让Etcd系统始终保持稳稳当当的工作状态,就像一台永不停歇的精密时钟一样稳定可靠。 最后,我们要记住的是,无论我们使用何种技术,都无法完全消除所有可能的风险。所以呢,咱们得随时绷紧这根弦儿,时不时给咱们的系统做个全身检查和保养,好让它们随时都能活力满满、状态最佳地运转起来。
2023-05-20 11:27:36
520
追梦人-t
Etcd
...称K8s)是一个开源容器管理系统,由Google开发并捐赠给Cloud Native Computing Foundation管理。它为容器化应用提供了部署、自动扩展、负载均衡以及自我修复等功能,利用Etcd来持久化和同步集群的状态信息,以实现对整个集群资源的有效管理和调度。 分布式键值存储 , 分布式键值存储是一种数据存储架构,其中数据以键值对的形式分散存储在网络中多个节点上,具有高可用性、容错性和可扩展性等特点。在本文语境下,Etcd就是这样一个系统,允许用户通过一个简单的接口,将数据关联到唯一的键并在分布式环境中进行读写操作,广泛应用于服务发现、协调和配置管理等方面。 Raft一致性算法 , Raft是一致性算法的一种,专为解决分布式系统中多个服务器之间的状态同步问题而设计。在Etcd中,Raft负责维护集群成员间的共识,保证在任何时候集群内部对于任何一条数据的修改都能达成一致,并且保证即使在部分节点失效的情况下,整个系统的可用性和数据完整性不受影响。 防火墙规则 , 防火墙规则是指网络防火墙为了控制进出网络的数据流而设立的一系列策略。这些规则通常基于源IP地址、目标IP地址、端口号以及传输协议等多种因素,决定是否允许或阻止特定的数据包通过。在本文中,作者指导如何配置Linux和Windows系统的防火墙规则,以便开放Etcd所需的2379和2380端口,确保集群间可以正常通信。
2023-05-11 17:34:47
642
醉卧沙场-t
Golang
...编程的注意事项与常见问题解析 在编程世界中,Golang(又称Go语言)以其独特的并发模型和高效的性能赢得了广大开发者的青睐。本文将深入探讨Golang并发编程的一些关键注意事项,并通过丰富的代码示例,带大家理解并解决在实际应用中可能遇到的常见问题。 1. Goroutine 轻量级线程的灵魂 Goroutine是Golang并发编程的核心概念,它是一种用户态的轻量级线程,由Go运行时管理而非操作系统内核,创建和销毁的成本极低。 go func main() { // 创建一个goroutine go func() { fmt.Println("Hello from a goroutine!") }() // 主goroutine继续执行 fmt.Println("Hello from the main goroutine!") } 上述代码展示了如何启动一个新的goroutine,可以看到,创建goroutine就像调用一个函数一样简单。在处理并发的情况时,大伙儿可得留心了,这Goroutine的执行顺序啊,可不是板上钉钉的事儿。为啥呢?因为它们是同步进行、各干各活的,所以谁先谁后,那真说不准,全看“缘分”啦! 2. Channel 同步通信的关键 Goroutine之间的通信主要依赖于Channel,它是Golang并发安全的数据传输通道,能有效地解决竞态条件和数据同步问题。 go // 创建一个int类型的channel ch := make(chan int) go func() { ch <- 42 // 向channel中发送数据 }() value := <-ch // 从channel中接收数据 fmt.Println("Received value:", value) 这段代码展示了如何通过channel进行goroutine间的数据传递。在实际操作时,咱们得小心翼翼地对待channel的读写动作,就像是捧着个易碎品,一不留神就可能惹出死锁或者数据溢出这些麻烦事。 3. 注意事项 Goroutine泄漏 由于Goroutine的创建成本低廉,如果不加以控制,可能会导致大量未被回收的“僵尸”Goroutine,从而引发资源泄露。 go for { go neverEndingTask() } // 这将创建无限多的goroutine,造成资源泄漏 为了避免这种情况,我们需要确保每个Goroutine都有明确的退出机制或者生命周期,例如通过channel通知其完成任务后退出。 4. 常见问题 竞态条件与互斥锁 在并发编程中,竞态条件是一个常见的问题。Golang提供了sync.Mutex等工具来保证在同一时间只有一个goroutine访问共享资源。 go var counter int var mutex sync.Mutex func incrementCounter() { mutex.Lock() defer mutex.Unlock() counter++ } // 在多个goroutine中同时调用incrementCounter() 在这个例子中,mutex确保了counter的原子性增一操作,防止因并发修改而产生的竞态条件问题。 总结来说,Golang并发编程既强大又优雅,但同时也需要我们对并发原理有深刻理解,遵循一定的规范和注意事项,才能充分利用其优势,避免潜在的问题。希望这篇东西能实实在在帮到你,让你更好地掌握Golang的并发技巧,让你的代码跑得更溜、更稳当,就像是一辆上了赛道的F1赛车,既快又稳。在实际敲代码的过程中,不断动手尝试、开动脑筋琢磨、勇往直前地探索,你绝对能亲身体验到Golang并发编程那让人乐此不疲的魅力所在。
2023-05-22 19:43:47
650
诗和远方
MemCache
...。近期,为了解决类似问题并提升性能,一些新型缓存系统如Redis等开始采用更先进的锁机制。 例如,Redis提供了多种类型的分布式锁实现,包括基于SETNX命令实现的基本分布式锁,以及使用Lua脚本实现的Redlock算法,这种算法通过在多个Redis节点上获取锁以提高容错性和安全性。另外,还有乐观锁(Optimistic Locking)的设计理念也被越来越多地应用于现代缓存服务中,它假设并发访问一般情况下不会发生冲突,仅在更新数据时检查是否发生并发修改,从而降低锁带来的性能开销。 此外,云原生时代的容器化与微服务架构也对缓存系统的并发控制提出了新的挑战。Kubernetes等容器编排平台上的应用实例可能随时扩缩容,这要求缓存服务不仅要处理好内部的多线程同步问题,还要适应外部动态环境的变化。因此,诸如具有更强一致性保证的CRDT(Conflict-free Replicated Data Types)数据结构的研究与应用也在不断推进,旨在提供一种更为灵活且能应对网络分区的分布式锁方案。 综上所述,理解并妥善处理Memcache乃至更多现代缓存系统中的锁机制冲突,是构建高性能、高可用分布式系统的基石,而紧跟技术发展趋势,关注相关领域的最新研究成果与实践案例,将有助于我们在实际工作中更好地解决此类问题。
2024-01-06 22:54:25
78
岁月如歌-t
Etcd
...ubernetes、Docker Swarm等容器编排系统中发挥着至关重要的作用。然而,在实际操作的时候,我们可能会遇到一个叫做“数据压缩错误”的小插曲。这篇东西,咱就以这个主题为核心,从原理的揭秘、原因的深度剖析,一路谈到解决方案,还会配上实例代码,来个彻彻底底的大讨论,保证接地气儿,让你看明白了。 1. Etcd的数据压缩机制简介 首先,让我们简单了解一下Etcd的数据压缩机制。Etcd这小家伙为了能更节省存储空间,同时还想跑得更快、更强悍,就选择了Snappy这个压缩算法来帮它一把,把数据压缩得更紧实。每当Etcd这个小家伙收到新的键值对更新时,它就像个认真的小会计,会把这些变动一笔一划地记在“事务操作”的账本上。然后呢,再把这一连串的账目整理打包,变成一个raft log entry的包裹。最后,为了省点空间和让传输更轻松流畅,Etcd还会把这个包裹精心压缩一下,这样一来,存储成本和网络传输的压力就减轻不少啦! go // 这是一个简化的示例,展示Etcd内部如何使用Snappy压缩数据 import ( "github.com/golang/snappy" ) func compress(data []byte) ([]byte, error) { compressed, err := snappy.Encode(nil, data) if err != nil { return nil, err } return compressed, nil } 2. 数据压缩错误Datacompressionerror的发生原因 然而,数据压缩并非总是顺利进行。在某些情况下,Etcd在尝试压缩raft日志条目时可能会遇到"Datacompressionerror"。这通常由以下原因引起: - 输入数据不合规:当待压缩的数据包含无法被Snappy识别或处理的内容时,就会抛出此错误。 - 内存限制:如果系统的可用内存不足,可能导致Snappy在压缩过程中失败。 - Snappy库内部错误:极少数情况下,可能是Snappy库本身存在bug或者与当前系统环境不兼容导致的。 3. 遇到Datacompressionerror的排查方法 假设我们在使用Etcd的过程中遭遇了此类错误,可以按照以下步骤进行排查: 步骤一:检查日志 查看Etcd的日志输出,定位错误发生的具体事务以及可能触发异常的数据内容。 步骤二:模拟压缩 通过编写类似上面的代码片段,尝试用Snappy压缩可能出现问题的数据部分,看是否能重现错误。 步骤三:资源监控 确保服务器有足够的内存资源用于Snappy压缩操作。可以通过系统监控工具(如top、htop等)实时查看内存使用情况。 步骤四:版本验证与升级 确认使用的Etcd及Snappy库版本,并查阅相关文档,看看是否有已知的关于数据压缩问题的修复版本,如有必要,请及时升级。 4. 解决Datacompressionerror的方法与实践 针对上述原因,我们可以采取如下措施来解决Datacompressionerror: - 清理无效数据:若发现特定的键值对导致压缩失败,应立即移除或修正这些数据。 - 增加系统资源:确保Etcd运行环境拥有足够的内存资源以支持正常的压缩操作。 - 升级依赖库:如确定是由于Snappy库的问题引起的,应尽快升级至最新稳定版或已知修复该问题的版本。 go // 假设我们需要删除触发压缩错误的某个键值对 import ( "go.etcd.io/etcd/clientv3" ) func deleteKey(client clientv3.Client, key string) error { _, err := client.Delete(context.Background(), key) return err } // 调用示例 err := deleteKey(etcdClient, "problematic-key") if err != nil { log.Fatal(err) } 总之,面对Etcd中的"data compression error",我们需要深入了解其背后的压缩机制,理性分析可能的原因,并通过实例代码演示如何排查和解决问题。在这个过程中,我们不光磨炼了搞定技术难题的硬实力,更是亲身感受到了软件开发实战中那份必不可少的探索热情和动手实践的乐趣。就像是亲手烹饪一道复杂的菜肴,既要懂得菜谱上的技术窍门,也要敢于尝试、不断创新,才能最终端出美味佳肴,这感觉倍儿爽!希望这篇文章能帮助你在遇到此类问题时,能够快速找到合适的解决方案。
2023-03-31 21:10:37
440
半夏微凉
ZooKeeper
...的协调服务以及一致性问题有了更深层次的认识。为了进一步探究这一领域的最新发展和实践应用,以下是一些针对性的延伸阅读建议: 1. 最新研究进展:《CAP理论与现代分布式系统的权衡》——此篇论文详细探讨了在分布式系统中如何平衡一致性、可用性和分区容错性(CAP定理),并结合当下前沿技术,如Raft协议等,分析了其在ZooKeeper之外的其他分布式协调服务中的应用。 2. 实时案例分享:《大型互联网公司如何利用ZooKeeper优化分布式架构》——该篇文章通过实际案例剖析了某知名互联网公司在面临大规模分布式环境下的数据一致性挑战时,如何巧妙运用ZooKeeper设计原则进行优化,并取得显著效果。 3. 技术深度解读:《ZooKeeper 4.x版本新特性解析及实战指南》——随着ZooKeeper版本的迭代更新,新特性如增强的性能、改进的一致性保障机制以及更加灵活的API都为开发者提供了更多选择。本文将深入解读这些新特性的实现原理及其在实际项目中的最佳实践。 4. 行业动态观察:《云原生时代下,ZooKeeper面临的挑战与机遇》——随着云计算和容器化技术的发展,ZooKeeper作为传统的分布式协调服务,在云原生环境下面临着新的挑战和机遇。该篇报道分析了ZooKeeper如何适应快速变化的技术趋势,并与其他新兴的分布式协调工具进行比较,展望未来发展趋势。 5. 开源社区热点:《Apache Curator库在ZooKeeper使用中的重要角色》——Curator是专为ZooKeeper设计的开源Java客户端库,它简化了ZooKeeper的复杂操作,提供了一套高级API以更好地遵循ZooKeeper的设计原则。了解Curator的应用可以加深对ZooKeeper在实际开发中高效利用的理解。 以上延伸阅读内容旨在帮助读者紧跟分布式系统领域的发展步伐,从理论到实践全方位拓展对ZooKeeper设计原则的认知和应用能力。
2024-02-15 10:59:33
31
人生如戏-t
c++
...争条件和数据不一致等问题。例如,使用互斥锁(mutex)、读写锁(read-write locks)或原子操作等技术来保证线程安全。 2. 跨平台兼容性:不同操作系统和硬件平台对资源管理的支持程度不同。确保资源管理代码在各种环境中都能正确运行,需要考虑平台差异和标准一致性。 3. 性能优化:资源管理操作,如资源获取和释放,可能会对程序性能产生影响。在追求资源管理的同时,需要平衡性能需求,避免不必要的开销。 4. 资源泄露与内存管理:在动态分配资源的情况下,确保资源在不再需要时被正确释放,是避免内存泄漏和资源泄露的关键。智能指针虽然有效,但在某些场景下仍需谨慎使用,特别是在与第三方库交互时。 应对策略 1. 采用现代C++特性:利用C++11及之后版本的特性,如范围基类(range-based for loops)、智能指针(std::unique_ptr, std::shared_ptr)和RAII原则,简化资源管理过程,提高代码可读性和安全性。 2. 使用线程安全库:选择支持线程安全的库,如Boost.Thread或Intel TBB(Threading Building Blocks),可以简化多线程编程,减少资源管理相关的错误。 3. 深入理解并使用现代内存管理技术:掌握C++的智能指针、RAII、RAII原则和现代内存管理概念,如RAII(Resource Acquisition Is Initialization),能够有效地管理资源,减少内存泄漏的风险。 4. 性能优化与测试:在实现资源管理策略时,结合性能分析工具(如Valgrind、gperftools)进行性能评估,确保资源管理操作不会对程序性能产生负面影响。同时,进行充分的单元测试和压力测试,验证资源管理的正确性和鲁棒性。 5. 持续学习与适应新技术:软件开发领域不断演进,新技术和最佳实践层出不穷。持续关注C++和软件工程领域的最新发展,学习新的资源管理工具和技术,如现代容器类库(如std::optional, std::variant)和并发库,能够帮助开发者更好地应对资源管理的挑战。 通过上述策略,开发者可以更有效地管理资源,确保程序在各种复杂场景下的稳定性和安全性,同时优化性能,满足现代软件开发的需求。
2024-10-05 16:01:00
48
春暖花开
转载文章
...ubernetes、Docker等容器技术与Java结合日益紧密,使得Java应用能够更好地适应微服务架构的需求,实现快速部署和弹性伸缩。同时,Java也正在积极拥抱无服务器(Serverless)计算模式,通过与AWS Lambda、Google Cloud Functions等服务集成,为开发者提供更为便捷高效的开发体验。 综上所述,Java语言在不断发展演进中保持活力,并且在全球范围内继续影响和塑造着软件开发的趋势与格局。无论是初学者还是资深开发者,关注Java最新动态和技术进展,都将有助于把握未来编程语言的发展脉络,提升自身的技术实力与竞争力。
2023-03-25 09:18:50
84
转载
转载文章
...NTP) 是一种确保时钟保持准确的方法。如果可以访问互联网,只需安装ntp的客户端软件到互联网上的公共ntp服务器自动修正时间即可 一、系统时间和硬件时间 Linux在默认情况下,系统时间和硬件时间并不会自动同步。而是以异步的方式运行,互不干扰。其中硬件时间的运行,是靠Bios电池来维持,而系统时间,是用CPU 时钟来维持的。 在系统开机的时候,会自动从Bios中取得硬件时间,设置为系统时间。 1.1 date命令 用来查看和设置系统时间 date 查看系统当前时间sudo date -s "2023-03-18 11:16:10" 修改系统时间为 "xxxx-xx-xx xx:xx:xx"===============================================================================nvidia@nvidia-desktop:~$ dateВт мар 18 11:16:27 +08 2023nvidia@nvidia-desktop:~$nvidia@nvidia-desktop:~$nvidia@nvidia-desktop:~$ sudo date -s "2023-03-18 11:16:10"[sudo] password for nvidia:Вт мар 18 11:16:10 +08 2023nvidia@nvidia-desktop:~$ 硬件时间的设置,可以用hwclock 1.2 hwclock 命令 查看当前硬件时间 注意:hwclock 所有命令需要使用root 权限 nvidia@nvidia-desktop:~$ hwclockhwclock: Cannot access the Hardware Clock via any known method.hwclock: Use the --debug option to see the details of our search for an access method.nvidia@nvidia-desktop:~$nvidia@nvidia-desktop:~$nvidia@nvidia-desktop:~$ sudo hwclock2023-03-21 11:18:49.607690+0800nvidia@nvidia-desktop:~$ 将系统时间同步到硬件时间 hwclock -w 将硬件时间同步到系统时间 hwclock -s 二、不同机器间时间同步 为了避免主机时间因为长期运作下所导致的时间偏差,进行时间同步(synchronize)的工作是非常必要的。Linux系统下,一般使用ntp服务器来同步不同机器的时间。一台机器,可以同时是ntp服务器和ntp客户机。 2.1 ntpdate命令实现 ntpdate 安装: yum install ntpdate -y Centos系统======================================sudo apt install ntpdate Ubuntu系统 时间同步 sudo ntpdate -u cn.pool.ntp.org18 Mar 18:25:22 ntpdate[18673]: adjust time server 84.16.73.33 offset 0.015941 sec 使用ntpdate 只是强制将系统时间设置为ntp服务器时间,如果cpu tick有问题,时间还是会不准。所以,一般配合cron命令,来进行定期同步设置。比如,在crontab中添加: sudo crontab -e0 12 /usr/sbin/ntpdate 192.168.10.110 上述命令的意思是:每天的12点整,从192.168.10.110 ntp服务器同步一次时间(前提是 192.168.10.110有ntp服务)。 2.2 Ntp客户端代码实现 本质上还是创建socket连接去获取ntp服务的时间与本地时间比较,不一致修改本机时间即可。 NtpClient.h //// Created by lwang on 2023-03-18.//ifndef NTP_CLIENT_Hdefine NTP_CLIENT_Hinclude <stdio.h>include <stdlib.h>include <string.h>include <time.h>include <iostream>include <unistd.h>include <sys/select.h>include <sys/time.h>include <sys/socket.h>include <arpa/inet.h>include <netdb.h>include <errno.h>include <endian.h>include <map>include <string>include <mutex>using namespace std;define NTP_LI 0define NTP_VERSION_NUM 3define NTP_MODE_CLIENT 3define NTP_MODE_SERVER 4define NTP_STRATUM 0define NTP_POLL 4define NTP_PRECISION -6define NTP_MIN_LEN 48define NTP_SERVER_PORT 123define NTP_SERVER_ADDR "119.28.183.184"define TIMEOUT 2define BUFSIZE 1500define JAN_1970 0x83aa7e80define NTP_CONV_FRAC32(x) (uint64_t)((x) ((uint64_t)1 << 32))define NTP_REVE_FRAC32(x) ((double)((double)(x) / ((uint64_t)1 << 32)))define NTP_CONV_FRAC16(x) (uint32_t)((x) ((uint32_t)1 << 16))define NTP_REVE_FRAC16(x) ((double)((double)(x) / ((uint32_t)1 << 16)))define USEC2FRAC(x) ((uint32_t)NTP_CONV_FRAC32((x) / 1000000.0))define FRAC2USEC(x) ((uint32_t)NTP_REVE_FRAC32((x)1000000.0))define NTP_LFIXED2DOUBLE(x) ((double)(ntohl(((struct l_fixedpt )(x))->intpart) - JAN_1970 + FRAC2USEC(ntohl(((struct l_fixedpt )(x))->fracpart)) / 1000000.0))struct s_fixedpt{uint16_t intpart;uint16_t fracpart;};struct l_fixedpt{uint32_t intpart;uint32_t fracpart;};struct ntphdr{if __BYTE_ORDER == __BID_ENDIANunsigned int ntp_li : 2;unsigned int ntp_vn : 3;unsigned int ntp_mode : 3;endifif __BYTE_ORDER == __LITTLE_ENDIANunsigned int ntp_mode : 3;unsigned int ntp_vn : 3;unsigned int ntp_li : 2;endifuint8_t ntp_stratum;uint8_t ntp_poll;int8_t ntp_precision;struct s_fixedpt ntp_rtdelay;struct s_fixedpt ntp_rtdispersion;uint32_t ntp_refid;struct l_fixedpt ntp_refts;struct l_fixedpt ntp_orits;struct l_fixedpt ntp_recvts;struct l_fixedpt ntp_transts;};class NtpClient {public:NtpClient();virtual ~NtpClient();void GetNtpTime(std::string &ntpTime);in_addr_t HostTransfer(const char host);int PaddingNtpPackage(void buf, size_t size);double GetOffset(const struct ntphdr ntp, const struct timeval recvtv);private:int m_sockfd;};endif / NTP_CLIENT_H / NtpClient.cpp //// Created by lwang on 2023-03-18.//include "NtpClient.h"NtpClient::NtpClient() { }NtpClient::~NtpClient() {}in_addr_t NtpClient::HostTransfer(const char host){in_addr_t saddr;struct hostent hostent;if ((saddr = inet_addr(host)) == INADDR_NONE){if ((hostent = gethostbyname(host)) == NULL){return INADDR_NONE;}memmove(&saddr, hostent->h_addr, hostent->h_length);}return saddr;}int NtpClient::PaddingNtpPackage(void buf, size_t size) // 构建并发送NTP请求报文{if (!size)return -1;struct ntphdr ntp;struct timeval tv;memset(buf, 0, BUFSIZE);ntp = (struct ntphdr )buf;ntp->ntp_li = NTP_LI;ntp->ntp_vn = NTP_VERSION_NUM;ntp->ntp_mode = NTP_MODE_CLIENT;ntp->ntp_stratum = NTP_STRATUM;ntp->ntp_poll = NTP_POLL;ntp->ntp_precision = NTP_PRECISION;gettimeofday(&tv, NULL); // 把目前的时间用tv 结构体返回ntp->ntp_transts.intpart = htonl(tv.tv_sec + JAN_1970);ntp->ntp_transts.fracpart = htonl(USEC2FRAC(tv.tv_usec));size = NTP_MIN_LEN;return 0;}double NtpClient::GetOffset(const struct ntphdr ntp, const struct timeval recvtv) // 偏移量{double t1, t2, t3, t4;t1 = NTP_LFIXED2DOUBLE(&ntp->ntp_orits);t2 = NTP_LFIXED2DOUBLE(&ntp->ntp_recvts);t3 = NTP_LFIXED2DOUBLE(&ntp->ntp_transts);t4 = recvtv->tv_sec + recvtv->tv_usec / 1000000.0;return ((t2 - t1) + (t3 - t4)) / 2;}void NtpClient::GetNtpTime(std::string &ntpTime){char buffer[64] = {0};char cmd[128] = {0};tm local;char buf[BUFSIZE];size_t nbytes;int maxfd1;struct sockaddr_in servaddr;fd_set readfds;struct timeval timeout, recvtv, tv;double offset;servaddr.sin_family = AF_INET;servaddr.sin_port = htons(NTP_SERVER_PORT);servaddr.sin_addr.s_addr = HostTransfer(NTP_SERVER_ADDR);if ((m_sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0){perror("socket error");return ;}if (connect(m_sockfd, (struct sockaddr )&servaddr, sizeof(struct sockaddr)) != 0){perror("connect error");return ;}nbytes = BUFSIZE;if (PaddingNtpPackage(buf, &nbytes) != 0){fprintf(stderr, "construct ntp request error \n");exit(-1);}send(m_sockfd, buf, nbytes, 0);FD_ZERO(&readfds);FD_SET(m_sockfd, &readfds);maxfd1 = m_sockfd + 1;timeout.tv_sec = TIMEOUT;timeout.tv_usec = 0;if (select(maxfd1, &readfds, NULL, NULL, &timeout) > 0){if (FD_ISSET(m_sockfd, &readfds)){if ((nbytes = recv(m_sockfd, buf, BUFSIZE, 0)) < 0){perror("recv error");exit(-1);}// 计算C/S时间偏移量gettimeofday(&recvtv, NULL);offset = GetOffset((struct ntphdr )buf, &recvtv);gettimeofday(&tv, NULL);tv.tv_sec += (int)offset;tv.tv_usec += offset - (int)offset;local = localtime((time_t )&tv.tv_sec);strftime(buffer, 64, "%Y-%m-%d %H:%M:%S", local);ntpTime = std::string(buffer);} }return ;} main.cpp include "NtpClient.h"int main(){std::string ntpTime = "";char curBuf[64] = {0};struct timeval cur;tm local;NtpClient client;client.GetNtpTime(ntpTime);cout << "ntpTime: " << ntpTime << endl;gettimeofday(&cur, NULL);local = localtime((time_t )&cur.tv_sec);strftime(curBuf, 64, "%Y-%m-%d %H:%M:%S", local);std::string curTime = std::string(curBuf);cout << "curTime: " << curTime << endl;if (curTime != ntpTime){cout << "start time calibrate!" << endl;std::string cmd = "sudo date -s \"" + ntpTime + "\"";system(cmd.c_str());cout << "cmd: " << cmd << endl;}else{cout << "time seem" << endl;}return 0;} 推荐一个零声学院免费教程,个人觉得老师讲得不错, 分享给大家:[Linux,Nginx,ZeroMQ,MySQL,Redis, fastdfs,MongoDB,ZK,流媒体,CDN,P2P,K8S,Docker, TCP/IP,协程,DPDK等技术内容,点击立即学习: 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_46935110/article/details/129683157。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-03-01 12:56:47
112
转载
站内搜索
用于搜索本网站内部文章,支持栏目切换。
知识学习
实践的时候请根据实际情况谨慎操作。
随机学习一条linux命令:
tail -n 10 file.txt
- 查看文件后10行。
推荐内容
推荐本栏目内的其它文章,看看还有哪些文章让你感兴趣。
2023-04-28
2023-08-09
2023-06-18
2023-04-14
2023-02-18
2023-04-17
2024-01-11
2023-10-03
2023-09-09
2023-06-13
2023-08-07
2023-03-11
历史内容
快速导航到对应月份的历史文章列表。
随便看看
拉到页底了吧,随便看看还有哪些文章你可能感兴趣。
时光飞逝
"流光容易把人抛,红了樱桃,绿了芭蕉。"