当前位置: 首页 > news >正文

我做的网站搜不到免费推广预期效果怎么写

我做的网站搜不到,免费推广预期效果怎么写,开发公司年度工作计划,wordpress书画代码示例及原理 原理是利用websocket协议实现对pod的exec登录#xff0c;利用client-go构造与远程apiserver的长连接#xff0c;将对pod容器的输入和pod容器的输出重定向到我们的io方法中#xff0c;从而实现浏览器端的虚拟终端的效果消息体结构如下 type Connection stru…代码示例及原理 原理是利用websocket协议实现对pod的exec登录利用client-go构造与远程apiserver的长连接将对pod容器的输入和pod容器的输出重定向到我们的io方法中从而实现浏览器端的虚拟终端的效果消息体结构如下 type Connection struct {WsSocket *websocket.Conn // 主websocket连接OutWsSocket *websocket.ConnInChan chan *WsMessage // 输入消息管道OutChan chan *WsMessage // 输出消息管道Mutex sync.Mutex // 并发控制IsClosed bool // 是否关闭CloseChan chan byte // 关闭连接管道 } // 消息体 type WsMessage struct {MessageType int json:messageTypeData []byte json:data } // terminal的行宽和列宽 type XtermMessage struct {Rows uint16 json:rowsCols uint16 json:cols }下面需要一个handler来控制终端和接收消息ResizeEvent用来控制终端变更的事件 type ContainerStreamHandler struct {WsConn *ConnectionResizeEvent chan remotecommand.TerminalSize }为了控制终端我们需要重写TerminalSize的Next方法这个方法是client-go定义的接口如下所示 /* Copyright 2017 The Kubernetes Authors.Licensed under the Apache License, Version 2.0 (the License); you may not use this file except in compliance with the License. You may obtain a copy of the License athttp://www.apache.org/licenses/LICENSE-2.0Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an AS IS BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */package remotecommand// TerminalSize and TerminalSizeQueue was a part of k8s.io/kubernetes/pkg/util/term // and were moved in order to decouple client from other term dependencies// TerminalSize represents the width and height of a terminal. type TerminalSize struct {Width uint16Height uint16 }// TerminalSizeQueue is capable of returning terminal resize events as they occur. type TerminalSizeQueue interface {// Next returns the new terminal size after the terminal has been resized. It returns nil when// monitoring has been stopped.Next() *TerminalSize }我们重写的Next方法如下 func (handler *ContainerStreamHandler) Next() (size *remotecommand.TerminalSize) {select {case ret : -handler.ResizeEvent:size retcase -handler.WsConn.CloseChan:return nil // 这里很重要, 具体见最后的解释}return }当我们从ResizeEvent管道中接收到调整终端大小的事件之后这个事件会被client-go接收到源码如下 func (p *streamProtocolV3) handleResizes() {if p.resizeStream nil || p.TerminalSizeQueue nil {return}go func() {defer runtime.HandleCrash()encoder : json.NewEncoder(p.resizeStream)for {size : p.TerminalSizeQueue.Next() // 接收到我们的调整终端大小的事件if size nil {return}if err : encoder.Encode(size); err ! nil {runtime.HandleError(err)}}}() }最后我们给出核心的实现(只是一个大概的框架具体细节有问题可以留言) func ExecCommandInContainer(ctx context.Context, conn *tty.Connection, podName, namespace, containerName string) (err error) {kubeClient, err : k8s.CreateClientFromConfig([]byte(env.Kubeconfig))if err ! nil {return}restConfig, err : clientcmd.RESTConfigFromKubeConfig([]byte(env.Kubeconfig))if err ! nil {return}// 构造请求req : kubeClient.CoreV1().RESTClient().Post().Resource(pods).Name(podName).Namespace(namespace).SubResource(exec).VersionedParams(corev1.PodExecOptions{Command: []string{/bin/sh, -c, export LANG\en_US.UTF-8\; [ -x /bin/bash ] exec /bin/bash || exec /bin/sh},Container: containerName,Stdin: true,Stdout: true,Stderr: true,TTY: true,}, scheme.ParameterCodec)// 使用spdy协议对http协议进行增量升级 exec, err : remotecommand.NewSPDYExecutor(restConfig, POST, req.URL())if err ! nil {return err}handler : tty.ContainerStreamHandler{WsConn: conn,ResizeEvent: make(chan remotecommand.TerminalSize),}// 核心函数重定向标准输入和输出err exec.StreamWithContext(ctx, remotecommand.StreamOptions{Stdin: handler,Stdout: handler,Stderr: handler,TerminalSizeQueue: handler,Tty: true,})return }整个函数的核心是StreamWithContext函数这个函数是client-go的一个方法接下来我们详细分析一下 // StreamWithContext opens a protocol streamer to the server and streams until a client closes // the connection or the server disconnects or the context is done. func (e *spdyStreamExecutor) StreamWithContext(ctx context.Context, options StreamOptions) error {conn, streamer, err : e.newConnectionAndStream(ctx, options)if err ! nil {return err}defer conn.Close()panicChan : make(chan any, 1) // panic管道errorChan : make(chan error, 1) // error管道go func() {defer func() {if p : recover(); p ! nil {panicChan - p}}()errorChan - streamer.stream(conn)}()select {case p : -panicChan:panic(p)case err : -errorChan:return errcase -ctx.Done():return ctx.Err()} }这个方法首先初始化了一个连接然后定义了两个管道分别接收panic事件和error事件核心是streamer.stream()方法接下来我们分析一下这个方法 func (p *streamProtocolV4) stream(conn streamCreator) error {// 创建一个与apiserver的连接传输流if err : p.createStreams(conn); err ! nil {return err}// now that all the streams have been created, proceed with reading copying// 观察流中的错误errorChan : watchErrorStream(p.errorStream, errorDecoderV4{})// 监听终端调整的事件p.handleResizes()// 将我们的标准输入拷贝到remoteStdin也就是远端的标准输入当中p.copyStdin()var wg sync.WaitGroup// 将远端的标准输出拷贝到我们的标准输出当中p.copyStdout(wg)p.copyStderr(wg)// were waiting for stdout/stderr to finish copyingwg.Wait()// waits for errorStream to finish reading with an error or nilreturn -errorChan }整体逻辑还是很清晰的具体实现细节看源码吧 OOM 问题 这个功能上线之后发现内存不断攀升如下图(出现陡降是因为我重启了服务) 使用pprof进行问题排查在你的main.go文件中加入下面的内容 import _ net/http/pproffunc main(){go func() {http.ListenAndServe(localhost:6060, nil)}() }然后你可以在http://localhost:6060/debug/pprof/中看到下面的页面 点击full goroutine stack dump你会看到goroutine的堆栈存储情况如下图 查看之后发现出现了很多的残留goroutine出现在Next方法中如下图 这个问题出现的原因是我们重写的Next方法当断开连接的时候必须要主动返回一个nil否则会残留一个go func具体看上面的handleResizes方法中有一个for循环必须收到一个size为nil才能跳出此func一开始我写的方法如下这样写的话当浏览器退出的时候是不会给我一个nil的终端调整的事件的 // 错误写法 func (handler *ContainerStreamHandler) Next() (size *remotecommand.TerminalSize) {ret : -handler.ResizeEvent:size retreturn } // 正确写法 func (handler *ContainerStreamHandler) Next() (size *remotecommand.TerminalSize) {select {case ret : -handler.ResizeEvent:size retcase -handler.WsConn.CloseChan:return nil // 当发现管道关闭的时候主动返回一个nil}return }有问题欢迎交流
http://www.tj-hxxt.cn/news/227621.html

相关文章:

  • 专业做汽配的网站企业网络广告推广方案
  • 淘宝客户自己做网站怎么做山东关键词网络推广
  • 网站开发制作熊掌号微信营销系统平台
  • 建立网站的正确方法设计一套企业网站多少钱
  • 建设网站的必要与可行性邯郸市教育考试院
  • 西安农产品网站建设做外单的网站
  • 登封做网站推广坂田做网站多少钱
  • 学校网站网站建设百度站长之家工具
  • 滨州正规网站建设哪家专业西八里庄网站建设
  • asp网站如何打开数据分析师一般一个月多少钱
  • icp网站备案信息表旅游电子商务的网站建设
  • 网站外包维护一年多少钱不知名网站开发
  • 公司 网站 苏州有没有做旅游攻略的网站
  • 旅游网站建设经费预算sem竞价推广托管代运营公司
  • 公司网站建设请示wordpress menu
  • 生产企业网站模板动态表单的设计与实现
  • 外贸网站怎么做seo优化济南行业网站开发
  • win7 iis设置网站首页中国人才网
  • 运城推广型网站建设crm客户管理系统论文
  • 美的技术网站阿里巴巴国际贸易网站推广工具
  • 成都医疗seo整站优化绑定网站
  • 厦门网站设计开发网页公司重新建设网站的请示
  • 专业定制网站建设智能优化网站建设课的感想
  • react可以做门户网站么深圳网站设计知名乐云seo
  • 网站开发与设计开题报告青岛网站建设方案外包
  • 太原市手机网站建设怎么查询自己房产信息
  • tk域名网站网站的空间和域名备案吗
  • 英迈思做网站怎么样dede单本小说网站源码
  • 保定网站建设多少钱哪家好Dw做网站怎么加logo
  • 做网站龙华h5页面制作平台