Statefulset 实战 1

news2024/11/15 13:44:41

上一部分与大家分享到 Statefulset 与 RplicaSet 的区别，以及 Statefulset 的特点，能做的一些事情及一些注意事项

现在我们来尝试使用 Statefulset 来部署我们的应用，我们可以需要有应用程序，然后有持久化卷

开始使用 Statefulset 部署应用

Statefulset 部署应用，我们需要完成这些资源的创建：

  • 制作应用程序和镜像
  • 编写 Service
  • 编写 Statefulset 指定 pod 模板及挂载

制作应用程序和镜像

编写应用程序

此处我们可以制作一个应用程序，会写数据到磁盘的某个路径下面，现在就用 golang 来简单写一个 http 服务器

  • 监听 8080 端口
  • 提供 GET 和 POST 请求
    • 收到 GET 请求的时候，读取 /var/data/stateful.txt 中的内容
    • 收到 POST 请求的时候，会将请求的内容写入到 /var/data/stateful.txt 文件中

文件目录是这样的

main.go 可以分为这几个部分

  • http 服务器部分

const (
	filePath = "/var/data/stateful.txt"
	fileDir  = "/var/data"
)

func main() {

	r := gin.Default()
	r.GET("/", func(c *gin.Context) {

		str, err := readFileContent(filePath)
		if err != nil {
			fmt.Println(" readFileContent err : ", err)
			return
		}
		//输出json结果给调用方
		c.JSON(200, gin.H{
			"message": str,
		})
	})
	r.POST("/", func(c *gin.Context) {
		buf := make([]byte, 1024)
		n, _ := c.Request.Body.Read(buf)
		fmt.Println(string(buf[0:n]))

		err := writeFileContent(filePath, buf[0:n])
		if err != nil {
			fmt.Println(" writeFileContent err : ", err)
			return
		}
		//输出json结果给调用方
		c.JSON(http.StatusOK, gin.H{
			"message": string(buf[0:n]),
		})
	})

	r.Run(":8080")
}

使用了 golang 中的 gin 框架，提供一个 GET 和 一个 POST 方法，GET 方法用于读取文件内容，POST 方法用于写入文件内容

  • 写文件部分
func processFileErr(err error, file string) (*os.File, error) {
	var f *os.File
	if os.IsNotExist(err) {
		gErr := os.MkdirAll(fileDir, 0775)
		if gErr != nil {
			fmt.Println("MkdirAll file error : ", gErr)
			return nil, gErr
		}
		f, gErr = os.Create(file)
		if gErr != nil {
			fmt.Println("Create file error : ", gErr)
			return nil, gErr
		}
	} else {
		fmt.Println("OpenFile file error : ", err)
		return nil, err
	}
	return f, nil
}

func writeFileContent(file string, content []byte) error {
	f, err := os.OpenFile(file, os.O_RDWR|os.O_CREATE|os.O_TRUNC, 0775)
	if err != nil {
		var pErr error
		f, pErr = processFileErr(err, file)
		if pErr != nil {
			fmt.Println("processFileErr error : ", pErr)
			return pErr
		}
	}
	defer f.Close()

	fmt.Println("Write content : ", string(content))

	_, err = f.Write(content)
	if err != nil {
		fmt.Println("Write file error : ", err)
		return err
	}
	return nil
}

writeFileContent 方法主要是用来写入数据到文件中

processFileErr 会处理文件不存在的错误信息，同时会创建不存在的路径和文件，并返回创建文件的文件指针

  • 读取文件信息部分
func readFileContent(file string) (string, error) {
	f, err := os.OpenFile(file, os.O_RDWR|os.O_CREATE, 0775)
	if err != nil {
		var pErr error
		f, pErr = processFileErr(err, file)
		if pErr != nil {
			fmt.Println("processFileErr error : ", pErr)
			return "", pErr
		}
	}

	defer f.Close()

	buf := make([]byte, 1024)
	n, err := f.Read(buf)
	if err == io.EOF {
		return "", nil
	}
	if err != nil {
		fmt.Println("Read file error : ", err)
	}
	fmt.Println("read content : ", string(buf))
	return string(buf[0:n]), nil
}

读取文件部分，同样需要使用 processFileErr 处理文件不存在的错误信息，主要是从传入的文件中读取文件内容，以字符串的形式作为函数返回值

制作镜像

Dockerfile：

将 myhttp 可执行程序加入到镜像中

FROM node:7
ADD myhttp /myhttp
ENTRYPOINT ["./myhttp"]

执行如下指令制作镜像：

看到这里的兄弟，请将镜像传到你自己的账号下面，记得登录哦

docker build -t xiaomotong888/sta-kubia .
docker push xiaomotong888/sta-kubia

上传镜像之后，我们可以通过 docker search 账号名 来查看自己的镜像列表，看到如下内容，说明可以往下继续完成其他步骤了

编写 Service

接下来便是编写 Service 部分的清单了，我们在玩 Statefulset 管理 pod 的时候，咱们创建的是有状态的 pod，咱们还需要创建一个 headless Service 来给 pod 之间提供网络标识

例如，我们可以这样来创建

sta-service.yaml

apiVersion: v1
kind: Service
metadata:
  name: sta-kubia
spec:
  clusterIP: None
  selector:
    app: sta-kubia
  ports:
  - name: http
    port: 80

创建的一个 Service

  • 名称为 sta-kubia
  • 选择的 pod 标签是 sta-kubia
  • svc 集群内部的端口是 80

这里需要注意的是，我们之前写 Service 清单的时候，如果不指定 type，那么 Service 默认是 clusterIP，但是现在我们是连 clusterIP 都不想要，我们需要将 clusterIP 置为 None

通过 kubectl create -f sta-service.yaml 创建一个 Service ，可以看到 CLUSTER-IP 一栏为 None 即为正确创建好 Service

curl localhost:8001/api/v1/namespaces/default/pods/sta-kubia-0/proxy/


curl  -X POST -d 'helloworld sta-kubia-0' localhost:8001/api/v1/namespaces/default/pods/sta-kubia-0/proxy/

今天就到这里，学习所得，若有偏差，还请斧正

欢迎点赞，关注，收藏

朋友们，你的支持和鼓励，是我坚持分享，提高质量的动力

好了，本次就到这里

技术是开放的，我们的心态，更应是开放的。拥抱变化，向阳而生，努力向前行。

我是阿兵云原生，欢迎点赞关注收藏，下次见~

更多的可以查看 零声每晚八点直播：https://ke.qq.com/course/417774

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

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

相关文章

28.利用fminsearch、fminunc 求解最大利润问题（matlab程序）

28.利用fminsearch、fminunc 求解最大利润问题（matlab程序）

1.简述 1.无约束（无条件）的最优化 fminunc函数 : - 可用于任意函数求最小值 - 统一求最小值问题 - 如求最大值问题： >对函数取相反数而变成求最小值问题，最后把函数值取反即为函数的最大值。 使用格式如下 1.必须预先把函数存…
阅读更多...
【机器学习】Gradient Descent for Logistic Regression

【机器学习】Gradient Descent for Logistic Regression

Gradient Descent for Logistic Regression 1. 数据集（多变量）2. 逻辑梯度下降3. 梯度下降的实现及代码描述3.1 计算梯度3.2 梯度下降 4. 数据集（单变量）附录 导入所需的库 import copy, math import numpy as np %matplotlib wi…
阅读更多...
Django的生命周期流程图(补充)、路由层urls.py文件、无名分组和有名分组、反向解析(无名反向解析、有名反向解析)、路由分发、伪静态

Django的生命周期流程图(补充)、路由层urls.py文件、无名分组和有名分组、反向解析(无名反向解析、有名反向解析)、路由分发、伪静态

一、orm的增删改查方法（补充） 1. 查询resmodels.表名(类名).objects.all()[0]resmodels.表名(类名).objects.filter(usernameusername, passwordpassword).all()res models.表名(类名).objects.first() # 判断，判断数据是否有# res如果查询…
阅读更多...
如何通过github学生包认证（远程不在学校或在校但位置报错均可用）

如何通过github学生包认证（远程不在学校或在校但位置报错均可用）

如何通过github学生包认证 在经历11次被拒绝，查阅多方博客后，终于成功通过了github的学生认证，材料每次重复的话github又会让你提交不同的材料，博主最后都已经要没有材料可以证明自己是学生了，不得不说这个认证是真的…
阅读更多...
git使用（由浅到深）

git使用（由浅到深）

目录流程图 1. 分布式版本控制与集中式版本控制 1.1 集中式版本控制 集中式版本控制系统有:CVS和SVN它们的主要特点是单一的集中管理的服务器，保存所有文件的修订版本；协同开发人员通过客户端连接到这台服务器，取出最新的文件或者提交更新…
阅读更多...
【C++】通讯录管理系统

【C++】通讯录管理系统

1.系统功能介绍与展示 2.创建项目 3.菜单功能 代码&#xff1a; //-封装函数显示该界面 如 void showMenu() //-在main函数中调用封装好的函数 #include <iostream> using namespace std;//-菜单界面 void showMenu() {cout << "***************************…
阅读更多...
Azure pipeline自动化打包发布

Azure pipeline自动化打包发布

pipeline自动化&#xff0c;提交代码后&#xff0c;就自动打包&#xff0c;打包成功后自动发布 第一步 pipeline提交代码后&#xff0c;自动打包。 1 在Repos,分支里选择要触发的分支&#xff0c;这里选择cn_china,对该分支设置分支策略 2 在生产验证中增加新的策略 3 在分支安…
阅读更多...
【Linux】yum工具的认识及使用

【Linux】yum工具的认识及使用

【Linux】yum工具的认识及使用 1.知识点补充2.yum是什么3.yum常用指令3.1查看软件安装包3.1.1关于rzsz 3.2安装软件3.3卸载软件 4.yum扩展4.1扩展14.2扩展24.3扩展3 什么是工具&#xff1f; 本质上也是指令 1.知识点补充 1.我们一般安装软件&#xff0c;是不是需要把软件安装…
阅读更多...
LabVIEW FPGA开发实时滑动摩擦系统

LabVIEW FPGA开发实时滑动摩擦系统

LabVIEW FPGA开发实时滑动摩擦系统 由于非线性摩擦效应的建模和补偿的固有困难&#xff0c;摩擦系统的运动控制已被广泛研究。最近&#xff0c;人们更加关注滑动动力学和滑动定位&#xff0c;作为传统机器人定位的低成本和更灵活的驱动替代方案。摩擦控制器设计和适当选择基础…
阅读更多...
JVM类加载器的作用和层次结构

JVM类加载器的作用和层次结构

类加载器的作用 1)通过一个类的全限定名来获取定义此类的二进制字节流。 2)将这个字节流所代表的静态存储结构转化为方法区的运行时数据结构。 3)在内存中生成一个代表这个类的java.lang.Class对象，这个对象存放在方法区中。这个对象将作为程序访问方法区中的这些数据的外部接…
阅读更多...
【嵌入式学习笔记】嵌入式入门2——中断（外部中断）

【嵌入式学习笔记】嵌入式入门2——中断（外部中断）

1.什么是中断 打断CPU执行正常的程序&#xff0c;转而处理紧急程序&#xff0c;然后返回原暂停的程序继续运行&#xff0c;就叫中断 1.1.中断的作用与意义 作用1&#xff1a;实时控制在确定时间内对相应事件作出响应——定时器中断作用2&#xff1a;故障处理检测到故障&…
阅读更多...
Linux内核的I2C驱动框架详解------这应该是我目前600多篇博客中耗时最长的一篇博客

Linux内核的I2C驱动框架详解------这应该是我目前600多篇博客中耗时最长的一篇博客

目录 1 I2C驱动整体框架图 2 I2C控制器 2.1 I2C控制器设备--I2C控制器在内核中也被看做一个设备 2.2 i2c控制器驱动程序 2.3 platform_driver结构体中的probe函数做了什么 2.3.1 疑问&#xff1a; i2cdev_notifier_call函数哪里来的 2.3.2 疑问&#xff1a;为什么有两…
阅读更多...
重生之我要学C++第六天

重生之我要学C++第六天

这篇文章的主要内容是const以及权限问题、static关键字、友元函数和友元类&#xff0c;希望对大家有所帮助&#xff0c;点赞收藏评论支持一下吧&#xff01; 更多优质内容跳转&#xff1a; 专栏&#xff1a;重生之C启程(文章平均质量分93) 目录 const以及权限问题 1.const修饰…
阅读更多...
管理类联考——数学——可视化篇——代数即几何

管理类联考——数学——可视化篇——代数即几何

数形结合百般好 代数即几何 两和三个数的完全平方和 https://www.bilibili.com/video/BV1zh4y137AY/ 立方差和立方和公式 通过图形得到立方差公式&#xff0c;将b换成-b&#xff0c;得到立方和公式 平方数列求和 https://www.bilibili.com/video/BV1vz4y1q75D/ 立方数列…
阅读更多...
[PAT乙级] 1029 旧键盘 C++实现

[PAT乙级] 1029 旧键盘 C++实现

题目描述&#xff1a; 旧键盘上坏了几个键&#xff0c;于是在敲一段文字的时候&#xff0c;对应的字符就不会出现。现在给出应该输入的一段文字、以及实际被输入的文字&#xff0c;请你列出肯定坏掉的那些键。 输入格式&#xff1a; 输入在 2 行中分别给出应该输入的文字、以…
阅读更多...
基于高通QCC5171的对讲机音频数据传输系统设计

基于高通QCC5171的对讲机音频数据传输系统设计

一 研发资料准备 二 设计方法 蓝牙连接与配对&#xff1a;使用QCC5171的蓝牙功能&#xff0c;实现设备之间的蓝牙连接和配对。确保设备能够相互识别并建立起稳定的蓝牙连接。 音频采集与处理&#xff1a;将麦克风采集到的音频数据通过QCC5171的ADC&#xff08;模数转换器&…
阅读更多...
简单的知识图谱可视化+绘制nx.Graph()时报错TypeError: ‘_AxesStack‘ object is not callable

简单的知识图谱可视化+绘制nx.Graph()时报错TypeError: ‘_AxesStack‘ object is not callable

绘制nx.Graph时报错TypeError: _AxesStack object is not callable 写在最前面知识图谱可视化预期报错可能的原因 原代码原因确认解决后的代码解决&#xff01; 写在最前面 实现一个简单的知识图谱的可视化功能。 使用了NetworkX库来构建知识图谱&#xff0c;并使用matplotlib…
阅读更多...
【面试题】 给你十万条数据，怎么样顺滑的渲染出来？

【面试题】 给你十万条数据，怎么样顺滑的渲染出来？

前端面试题库 &#xff08;面试必备&#xff09; 推荐&#xff1a;★★★★★ 地址&#xff1a;前端面试题库 前言 这是一道面试题&#xff0c;这个问题出来的一刹那&#xff0c;很容易想到的就是for循环100000次吧&#xff0c;但是这方案着实让浏览器崩溃啊&…
阅读更多...
基于LoRa无线数据传输的温湿度监测预警系统解决方案

基于LoRa无线数据传输的温湿度监测预警系统解决方案

为了维护仓储物品的品质&#xff0c;创造适宜的存储环境&#xff0c;就需要实时监测环境的温湿度信息&#xff0c;一旦温湿度出现异常就需要及时调整控制&#xff0c;从而保证品质稳定也能避免损失。 物通博联提供了软硬件一体的工业物联网解决方案&#xff0c;基于温湿度监测…
阅读更多...
2023年超越期待的高性能视频剪辑主机推荐| Intel 蝰蛇峡谷测评

2023年超越期待的高性能视频剪辑主机推荐| Intel 蝰蛇峡谷测评

1、开箱 蝰蛇峡谷的开箱体验是非常令人兴奋的。首先&#xff0c;打开包装后&#xff0c;你会看到一个精致且高质感的机箱&#xff0c;给人一种专业的感觉。蝰蛇峡谷的外观设计简洁大方&#xff0c;黑色的机箱与红色的Logo相得益彰&#xff0c;展现了其高性能的特点。 在打开机…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023