使用 .net + blazor 做一个 kubernetes 开源文件系统

深秋暖阳 發表於 2022-5-6 08:54:00

使用 .net + blazor 做一个 kubernetes 开源文件系统

<h2>背景</h2>
据我所知，目前 kubernetes 本身或者其它第三方社区都没提供 kubernetes 的文件系统。也就是说要从 kubernetes 的容器中下载或上传文件，需要先进入容器查看目录结构，然后再通过 kubectl cp 指令把文件拷贝进或出容器。虽然说不太麻烦，但也不太方便。当时正好推出 .net 5 + blazor，就趁着这个机会使用 .net 5 + blazor 做一个 kubernetes 的开源文件系统。
 
<h2>界面简介</h2>
<h4>创建集群</h4>
创建集群其实就是上传需要接管的 kubernetes 的 kubeconfig，并给集群取个帮助区分的名字：
<img src="https://img2022.cnblogs.com/blog/182190/202204/182190-20220424232130342-1653087637.png" alt="" loading="lazy">
 
<h4>浏览、上传、下载文件</h4>
创建完集群后，就可以方便地选择集群 -> 命名空间 -> Pod -> 容器，然后浏览容器目录，上传文件到容器，或者下载文件到本地：
<img src="https://img2022.cnblogs.com/blog/182190/202204/182190-20220424233126656-103899502.png" alt="" loading="lazy">
<h2> </h2>
<h2>使用方法</h2>
<ol>
<li>克隆代码，https://github.com/ErikXu/kubernetes-filesystem</li>
<li>安装 docker</li>
<li>执行 bash build.sh 指令</li>
<li>执行 bash pack.sh 指令</li>
<li>下载 kubectl 并保存到 /usr/local/bin/kubectl</li>
<li>执行 bash run.sh 指令</li>
</ol>
 
<h2>代码目录</h2>
<div class="cnblogs_Highlighter">
<pre class="brush:bash;gutter:false;">├── build.sh # 构建脚本
├── docker # docker 目录
│   └── Dockerfile # Dockerfile
├── pack.sh # 打包脚本
├── publish.sh # 发布脚本
├── README_CN.md # 项目说明（中文）
├── README.md # 项目说明
├── run.sh # 运行脚本
└── src # 源码目录
├── Kubernetes.Filesystem.sln # 解决方案
├── Web # Web 项目
│   ├── App.razor # 入口 APP
│   ├── _Imports.razor # 引用文件
│   ├── Pages
│   │   ├── Cluster.razor # 集群管理页面
│   │   └── File.razor # 文件管理页面
│   ├── Shared
│   │   ├── MainLayout.razor # 布局文件
│   │   ├── MainLayout.razor.css # 布局样式文件
│   │   ├── NavMenu.razor # 导航文件
│   │   ├── NavMenu.razor.css # 导航样式文件
│   │   └── SurveyPrompt.razor # 调查弹出框
│   ├── Web.csproj # Web 项目文件
│   └── wwwroot
│   ├── css # 样式文件夹
│   ├── favicon.ico # icon 文件
│   └── index.html # html 入口页
└── WebApi # WebApi 项目
 ├── appsettings.Development.json # 开发环境配置文件
 ├── appsettings.json # 配置文件
 ├── Controllers # 控制器目录
 │   ├── ClustersController.cs # 集群控制器
 │   ├── ContainersController.cs # 容器控制器
 │   ├── FilesController.cs # 文件控制器
 │   ├── NamespacesController.cs # 命名空间控制器
 │   └── PodsController.cs # Pod 控制器
 ├── Startup.cs # Startup 文件
 └── WebApi.csproj # WebApi 项目文件</pre>
</div>
<h2> </h2>
<h2>代码简析</h2>
<h4>ClustersController</h4>
ClustersController 主要对集群进行管理，集群信息使用 json 文件存储，路径为：/root/k8s-config。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_9a2ec43c-4b04-4844-a2d8-abd8640b387f" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_9a2ec43c-4b04-4844-a2d8-abd8640b387f" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_9a2ec43c-4b04-4844-a2d8-abd8640b387f" class="cnblogs_code_hide">
<pre>namespace WebApi
{
public class Program
{
 public static readonly string ConfigDir = "/root/k8s-config";

 ...
}
}</pre>
</div>
View Code</div>
 
构造函数主要创建 cluster json 文件及目录，并把 json 内容反序列化成 cluster list。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_7737a7c4-f8a0-496f-a998-5576433077fa" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_7737a7c4-f8a0-496f-a998-5576433077fa" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_7737a7c4-f8a0-496f-a998-5576433077fa" class="cnblogs_code_hide">
<pre>private readonly string _configName = "cluster.json";
private List<Cluster> _clusters;

public ClustersController()
{
_clusters = new List<Cluster>()
if (!Directory.Exists(Program.ConfigDir))
{
 Directory.CreateDirectory(Program.ConfigDir);

var configPath = Path.Combine(Program.ConfigDir, _configName);
if (!System.IO.File.Exists(configPath))
{
 var json = JsonConvert.SerializeObject(_clusters);
 System.IO.File.WriteAllText(configPath, json);
}
else
{
 var json = System.IO.File.ReadAllText(configPath);
 if (!string.IsNullOrWhiteSpace(json))
 {
 _clusters = JsonConvert.DeserializeObject<List<Cluster>>(json);
 }
}
}</pre>
</div>
View Code</div>
 
获取集群列表，直接返回 cluster json list。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_849d8e77-65cd-4c17-aabb-e3c60c873cf6" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_849d8e77-65cd-4c17-aabb-e3c60c873cf6" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_849d8e77-65cd-4c17-aabb-e3c60c873cf6" class="cnblogs_code_hide">
<pre>
public IActionResult List()
{
return Ok(_clusters);
}</pre>
</div>
View Code</div>
 
获取指定集群的详情信息，并读取 kubernetes 证书信息进行展示。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_1ab3b0da-e102-4a80-9822-9edab8734e15" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_1ab3b0da-e102-4a80-9822-9edab8734e15" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_1ab3b0da-e102-4a80-9822-9edab8734e15" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> Get(string id)
{
var cluster = _clusters.SingleOrDefault(n => n.Id == id);
if (cluster == null)
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var certificatePath = Path.Combine(Program.ConfigDir, cluster.Name);
var certificate = await System.IO.File.ReadAllTextAsync(certificatePath);
cluster.Certificate = certificate;

return Ok(cluster);
}</pre>
</div>
View Code</div>
 
获取指定集群的版本信息，主要使用 .net process + kubernetes 的证书执行 kubectl version --short 指令获取版本信息。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_a63fe5af-39cc-4957-802c-cf540d2734c2" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_a63fe5af-39cc-4957-802c-cf540d2734c2" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_a63fe5af-39cc-4957-802c-cf540d2734c2" class="cnblogs_code_hide">
<pre>
public IActionResult GetVersion(string id)
{
var cluster = _clusters.SingleOrDefault(n => n.Id == id);
if (cluster == null)
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var configPath = Path.Combine(Program.ConfigDir, cluster.Name.ToLower());

var command = $"kubectl version --short --kubeconfig {configPath}";

var (code, message) = ExecuteCommand(command);

if (code != 0)
{
 return StatusCode(StatusCodes.Status500InternalServerError, new { Message = message });
}

var lines = message.Split(Environment.NewLine);

var version = new ClusterVersion
{
 Client = lines[0].Replace("Client Version:", string.Empty).Trim(),
 Server = lines[1].Replace("Server Version:", string.Empty).Trim()
};

version.ClientNum = double.Parse(version.Client.Substring(1, 4));
version.ServerNum = double.Parse(version.Server.Substring(1, 4));

return Ok(version);
}</pre>
</div>
View Code</div>
 
创建集群，主要是上传集群证书，并把集群信息序列化成 json，并保存到文件。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_90af2dd3-32f8-4b95-be01-2c666da93c48" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_90af2dd3-32f8-4b95-be01-2c666da93c48" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_90af2dd3-32f8-4b95-be01-2c666da93c48" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> Create( Cluster cluster)
{
cluster.Name = cluster.Name.ToLower();
if (_clusters.Any(n => n.Name.Equals(cluster.Name)))
{
 return BadRequest(new { Message = "Cluster name is existed!" });
}

var certificatePath = Path.Combine(Program.ConfigDir, cluster.Name);
await System.IO.File.WriteAllTextAsync(certificatePath, cluster.Certificate);

cluster.Id = Guid.NewGuid().ToString();
cluster.Certificate = string.Empty;
_clusters.Add(cluster);
var json = JsonConvert.SerializeObject(_clusters);
var configPath = Path.Combine(Program.ConfigDir, _configName);
await System.IO.File.WriteAllTextAsync(configPath, json);

return Ok();
}</pre>
</div>
View Code</div>
 
更新集群，主要是更新集群证书及集群信息。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_8da25bba-f3da-4fd8-8bb6-3da294601f49" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_8da25bba-f3da-4fd8-8bb6-3da294601f49" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_8da25bba-f3da-4fd8-8bb6-3da294601f49" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> Update(string id, Cluster form)
{
var cluster = _clusters.SingleOrDefault(n => n.Id == id);
if (cluster == null)
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var certificatePath = Path.Combine(Program.ConfigDir, cluster.Name);
System.IO.File.Delete(certificatePath);

cluster.Name = form.Name;
certificatePath = Path.Combine(Program.ConfigDir, form.Name);
await System.IO.File.WriteAllTextAsync(certificatePath, form.Certificate);

var json = JsonConvert.SerializeObject(_clusters);
var configPath = Path.Combine(Program.ConfigDir, _configName);
await System.IO.File.WriteAllTextAsync(configPath, json);

return Ok();
}</pre>
</div>
View Code</div>
 
删除集群，主要是删除集群信息，并清理集群证书。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_57782998-72b9-42fd-bc4c-ef27061a3b9b" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_57782998-72b9-42fd-bc4c-ef27061a3b9b" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_57782998-72b9-42fd-bc4c-ef27061a3b9b" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> Delete(string id)
{
var cluster = _clusters.SingleOrDefault(n => n.Id == id);
if (cluster == null)
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

_clusters.Remove(cluster);

var certificatePath = Path.Combine(Program.ConfigDir, cluster.Name);
System.IO.File.Delete(certificatePath);

var configPath = Path.Combine(Program.ConfigDir, _configName);
var json = JsonConvert.SerializeObject(_clusters);
await System.IO.File.WriteAllTextAsync(configPath, json);

return NoContent();
}</pre>
</div>
View Code</div>
 
使用 .net process 执行 linux 指令的辅助函数。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_207e0959-49a9-4456-8bc3-827aa5e94fe2" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_207e0959-49a9-4456-8bc3-827aa5e94fe2" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_207e0959-49a9-4456-8bc3-827aa5e94fe2" class="cnblogs_code_hide">
<pre>private static (int, string) ExecuteCommand(string command)
{
var escapedArgs = command.Replace("\"", "\\\"");
var process = new Process
{
 StartInfo = new ProcessStartInfo
 {
 FileName = "/bin/sh",
 Arguments = $"-c \"{escapedArgs}\"",
 RedirectStandardOutput = true,
 RedirectStandardError = true,
 UseShellExecute = false,
 CreateNoWindow = true
 }
};

process.Start();
process.WaitForExit();

var message = process.StandardOutput.ReadToEnd();
if (process.ExitCode != 0)
{
 message = process.StandardError.ReadToEnd();
}

return (process.ExitCode, message);
}</pre>
</div>
View Code</div>
 
<h4>NamespacesController</h4>
NamespacesController 比较简单，主要是使用 kubernetes 证书 + kubernetes api 获取集群的命名空间列表。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_a30c197e-7395-4156-8b2d-3a85a6d7245c" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_a30c197e-7395-4156-8b2d-3a85a6d7245c" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_a30c197e-7395-4156-8b2d-3a85a6d7245c" class="cnblogs_code_hide">
<pre>
public IActionResult List( string cluster)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(configPath);
var client = new k8s.Kubernetes(config);
var namespaces = client.ListNamespace().Items.Select(n => n.Metadata.Name);
return Ok(namespaces);
}</pre>
</div>
View Code</div>
 
<h4>PodsController</h4>
PodsController 也比较简单，主要是获取指定命名空间下的 pod 列表，用于级联下拉菜单。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_41d46d07-7d2c-4df6-8330-213ed4ad7870" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_41d46d07-7d2c-4df6-8330-213ed4ad7870" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_41d46d07-7d2c-4df6-8330-213ed4ad7870" class="cnblogs_code_hide">
<pre>
public IActionResult List( string cluster, string @namespace)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(configPath);
var client = new k8s.Kubernetes(config);
var pods = client.ListNamespacedPod(@namespace).Items.Select(n => n.Metadata.Name);
return Ok(pods);
}</pre>
</div>
View Code</div>
 
<h4>ContainersController</h4>
ContainersController 也比较简单，主要是获取指定 pod 里的容器列表，用于级联下拉菜单。
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_aaea9ab6-741c-4203-9bf0-78277459eea2" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_aaea9ab6-741c-4203-9bf0-78277459eea2" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_aaea9ab6-741c-4203-9bf0-78277459eea2" class="cnblogs_code_hide">
<pre>
public IActionResult List( string cluster, string @namespace, string pod)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(configPath);
var client = new k8s.Kubernetes(config);
var specificPod = client.ListNamespacedPod(@namespace).Items.Where(n => n.Metadata.Name == pod).First();
var containers = specificPod.Spec.Containers.Select(n => n.Name);
return Ok(containers);
}</pre>
</div>
View Code</div>
 
<h4>FilesController</h4>
FilesController 是最重要，同时也是稍微有点复杂的一个控制器。
获取容器指定路径的文件列表，主要是调用 kubernetes api 的 exec 方法，执行指令 "ls -Alh --time-style long-iso {dir}" 获得文件内容信息。
由于 exec 是交互式的，所以方法使用的是 web socket：
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_67ebe7a7-d6f9-47f3-9c2f-d1d11273afc0" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_67ebe7a7-d6f9-47f3-9c2f-d1d11273afc0" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_67ebe7a7-d6f9-47f3-9c2f-d1d11273afc0" class="cnblogs_code_hide">
<pre>public async Task<IActionResult> List( string cluster, string @namespace, string pod, string container, string dir)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(configPath);
var client = new k8s.Kubernetes(config);

var webSocket = await client.WebSocketNamespacedPodExecAsync(pod, @namespace, new string[] { "ls", "-Alh", "--time-style", "long-iso", dir }, container).ConfigureAwait(false);
var demux = new StreamDemuxer(webSocket);
demux.Start();

var buff = new byte[4096];
var stream = demux.GetStream(1, 1);
stream.Read(buff, 0, 4096);
var bytes = TrimEnd(buff);
var text = System.Text.Encoding.Default.GetString(bytes).Trim();

var files = ToFiles(text);
return Ok(files);
}</pre>
</div>
View Code</div>
 
再看一下指令 "ls -Alh --time-style long-iso {dir}" 的一个例子：
<div class="cnblogs_code">
<pre>~ ls -Alh --time-style long-iso /usr/bin
total 107M
lrwxrwxrwx. 1 root root 8 2019-02-21 10:47 ypdomainname -> hostname
-rwxr-xr-x. 1 root root 62K2018-10-30 17:55 ar
drwxr-xr-x 8 root root 4.0K 2022-04-01 09:37 scripts</pre>
</div>
第一行 total 开头的信息不太重要可以忽略，从第二行可以看出，每一行的格式是固定的。
第 0 列：权限，l 开头表示是链接，- 开头表示是文件，d 开头表示是文件夹
第 1 列：link 数量
第 2 列：用户
第 3 例：组
第 4 列：文件（夹）大小
第 5 列：日期
第 6 列：时间
第 7 列：文件（夹）名称
如果记录类型为 l，则文件名称为 7，8，9 列合成。
因此，解析代码如下：
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_4cc0a8db-6c3e-465b-ac53-9a02120f6b0f" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_4cc0a8db-6c3e-465b-ac53-9a02120f6b0f" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_4cc0a8db-6c3e-465b-ac53-9a02120f6b0f" class="cnblogs_code_hide">
<pre>private static List<FileItem> ToFiles(string text)
{
var files = new List<FileItem>();

var lines = text.Split(Environment.NewLine);

foreach (var line in lines)
{
 if (line.StartsWith("total"))
 {
 continue;
 }
 var trimLine = line.Trim();
 var array = trimLine.Split(" ").ToList().Where(n => !string.IsNullOrWhiteSpace(n)).ToList();

 var file = new FileItem
 {
 Permission = array[0],
 Links = array[1],
 Owner = array[2],
 Group = array[3],
 Size = array[4],
 Date = array[5],
 Time = array[6],
 Name = array[7]
 };

 if (file.Permission.StartsWith("l"))
 {
 file.Name = $"{array} {array} {array}";
 }
 files.Add(file);
}

return files;
}</pre>
</div>
View Code</div>
 
上传文件主要是把文件上传到服务器，再使用 kubectl cp 指令把文件拷贝到指定容器中：
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_83518468-c499-478f-939e-ca856f28ba7f" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_83518468-c499-478f-939e-ca856f28ba7f" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_83518468-c499-478f-939e-ca856f28ba7f" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> UploadFile( string cluster, string @namespace, string pod, string container, string dir, IFormFile file)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var tmpPath = Path.Combine("/tmp", System.Guid.NewGuid().ToString());
await using (var stream = System.IO.File.Create(tmpPath))
{
 await file.CopyToAsync(stream);
}

var path = Path.Combine(dir, file.FileName);
var command = $"kubectl cp {tmpPath} {pod}:{path} -c {container} -n {@namespace} --kubeconfig {configPath}";
var (code, message) = ExecuteCommand(command);

System.IO.File.Delete(tmpPath);

if (code == 0)
{
 return Ok();
}

return StatusCode(StatusCodes.Status500InternalServerError, new { Message = message });
}</pre>
</div>
View Code</div>
 
下载文件主要是使用 kubectl cp 指令把文件从容器拷贝到服务器，再把文件读取下载：
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_a753337b-77ed-4404-a4b2-a8b1310352e2" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_a753337b-77ed-4404-a4b2-a8b1310352e2" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_a753337b-77ed-4404-a4b2-a8b1310352e2" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> DownloadFile( string cluster, string @namespace, string pod, string container, string path)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var tmpPath = Path.Combine("/tmp", System.Guid.NewGuid().ToString());
var command = $"kubectl cp {pod}:{path} {tmpPath} -c {container} -n {@namespace} --kubeconfig {configPath}";
var (code, message) = ExecuteCommand(command);

if (code != 0)
{
 return StatusCode(StatusCodes.Status500InternalServerError, new { Message = message });
}

var memory = new MemoryStream();
using (var stream = new FileStream(tmpPath, FileMode.Open))
{
 await stream.CopyToAsync(memory);
}
memory.Position = 0;

var contentType = GetContentType(tmpPath);

System.IO.File.Delete(tmpPath);

return File(memory, contentType);
}</pre>
</div>
View Code</div>
 
<h4>一个小插曲</h4>
有个哥们提了一个 issue 提到 kubernetes 在 1.20 引入了一个新指令 "kubectl debug"，目的是为了解决容器中未安装 bash 或者 sh 的问题。因此在新版本获取文件列表的方法中，我也实现了该指令：
<div class="cnblogs_code"><img src="https://images.cnblogs.com/OutliningIndicators/ContractedBlock.gif" id="code_img_closed_88a599c4-be49-4528-8818-78a70b71a7a4" class="code_img_closed"><img src="https://images.cnblogs.com/OutliningIndicators/ExpandedBlockStart.gif" id="code_img_opened_88a599c4-be49-4528-8818-78a70b71a7a4" class="code_img_opened" style="display: none">
<div id="cnblogs_code_open_88a599c4-be49-4528-8818-78a70b71a7a4" class="cnblogs_code_hide">
<pre>
public async Task<IActionResult> List( string cluster, string @namespace, string pod, string container, string dir)
{
var configPath = Path.Combine(Program.ConfigDir, cluster.ToLower());
if (!System.IO.File.Exists(configPath))
{
 return BadRequest(new { Message = "Cluster is not existed!" });
}

var command = $"kubectl version --short --kubeconfig {configPath}";

var (code, message) = ExecuteCommand(command);

if (code != 0)
{
 return StatusCode(StatusCodes.Status500InternalServerError, new { Message = message });
}

var lines = message.Split(Environment.NewLine);

var version = new ClusterVersion
{
 Client = lines[0].Replace("Client Version:", string.Empty).Trim(),
 Server = lines[1].Replace("Server Version:", string.Empty).Trim()
};

version.ClientNum = double.Parse(version.Client.Substring(1, 4));
version.ServerNum = double.Parse(version.Server.Substring(1, 4));

var text = string.Empty;
if (version.ClientNum >= 1.2 && version.ServerNum >= 1.2)
{
 command = $"kubectl debug -it {pod} -n {@namespace} --image=centos --target={container} --kubeconfig {configPath} -- sh -c 'ls -Alh --time-style long-iso {dir}'";
 (code, message) = ExecuteCommand(command);

 if (code != 0)
 {
 return StatusCode(StatusCodes.Status500InternalServerError, new { Message = message });
 }

 text = message;
}
else
{
 var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(configPath);
 var client = new k8s.Kubernetes(config);

 var webSocket = await client.WebSocketNamespacedPodExecAsync(pod, @namespace, new string[] { "ls", "-Alh", "--time-style", "long-iso", dir }, container).ConfigureAwait(false);
 var demux = new StreamDemuxer(webSocket);
 demux.Start();

 var buff = new byte[4096];
 var stream = demux.GetStream(1, 1);
 stream.Read(buff, 0, 4096);
 var bytes = TrimEnd(buff);
 text = System.Text.Encoding.Default.GetString(bytes).Trim();
}

var files = ToFiles(text);
return Ok(files);
}</pre>
</div>
View Code</div>
但意料之外的是，kubectl debug 里获取到的文件列表和容器的文件列表不一致，因此，如果想使用旧版本的方式，请使用 d293e34 版本的代码。
 
<h4>Cluster.razor 和 File.razor</h4>
界面部分相对比较简单，基本就是 Bootstrap 和一些 http client 的调用，请大家自行去查阅即可，有问题可以留言讨论。
 
<h2>项目地址</h2>
https://github.com/ErikXu/kubernetes-filesystem
欢迎大家 star，提 pr，提 issue，在文章留言交流，或者在公众号 - 跬步之巅留言交流。 
来源：https://www.cnblogs.com/Erik_Xu/p/16183765.html

頁: [1]

琼殿技术论坛's Archiver

使用 .net + blazor 做一个 kubernetes 开源文件系统