Fang's blog

    "repositories": [
        {
            "type": "path",
            "url": "D:\\projects\\imi"
        }
    ],

/**
 * 配置信息合并
 *
 * @param $arr1
 * @param $arr2
 * @return array
 */
if (!function_exists('array_recursive_merge')) {
    function array_recursive_merge($arr1, $arr2)
    {
        if(is_array($arr1) && is_array($arr2)) {
            foreach ($arr2 as $key => $item) {
                $arr1[$key] = array_recursive_merge($arr1[$key] ?? null, $item);
            }
            return $arr1;
        }
        return $arr2;
    }
}

//绑定配置文件加载事件
$app->afterBootstrapping(\Illuminate\Foundation\Bootstrap\LoadConfiguration::class, function($app){
    //检查是否存在config cache
    if($app->configurationIsCached()) {
        return;
    }

    $config = $app['config'];
    $url = $app['config']['config']['uri'] ?? null;
    if($url) {
        $appName = strtolower($app['config']['app']['name']);
        $env = strtolower($app['config']['app']['env']);
        $url .= $appName . '-' . $env . '.yml';
        $content = file_get_contents($url);
        if($content) {
            $content = \Symfony\Component\Yaml\Yaml::parse($content);
            foreach($content as $key=>$value) {
                $config[$key] = array_recursive_merge($config[$key]??null, $value);
            }
        }
    }

    //cache
    if($config['config']['cache'] ?? false) {
        $configPath = $app->getCachedConfigPath();
        (new Illuminate\Filesystem\Filesystem)->put(
            $configPath, '<?php return '.var_export($config->all(), true).';'.PHP_EOL
        );
    }

});


package components

import "fmt"
import "reflect"

//复制结构体中名称一致类型一致得字段
func CopyFields(des interface{}, src interface{}, fields ...string) (err error) {
at := reflect.TypeOf(des)
av := reflect.ValueOf(des)
bt := reflect.TypeOf(src)
bv := reflect.ValueOf(src)

// 简单判断下
if at.Kind() != reflect.Ptr {
err = fmt.Errorf("des must be a struct pointer")
return
}
av = reflect.ValueOf(av.Interface())

// 要复制哪些字段
_fields := make([]string, 0)
if len(fields) > 0 {
_fields = fields
} else {
for i := 0; i < bv.NumField(); i++ { _fields = append(_fields, bt.Field(i).Name) } } if len(_fields) == 0 { return } // 复制 for i := 0; i < len(_fields); i++ { name := _fields[i] f := av.Elem().FieldByName(name) bValue := bv.FieldByName(name) // a中有同名的字段并且类型一致才复制 if f.IsValid() && f.Kind() == bValue.Kind() && f.CanSet() { f.Set(bValue) } } return }


package components

import (
"bytes"
"encoding/json"
"errors"
"fmt"
"github.com/astaxie/beego/config"
"io"
"io/ioutil"
"net/http"
)

var (
defaultRpcConf config.Configer
)

type RpcResponse struct {
Id string `json:"id"`
Code string `json:"code"`
Message string `json:"message"`
Type string `json:"type"`
Payload interface{} `json:"payload"`
}

//发起远程调用
//TODO 鉴权可以在这里进行
func Request(url string, data io.Reader, payload* interface{}) (*RpcResponse, error) {
req,err := http.NewRequest("POST", url, data)
req.Header.Set("Content-Type", "application/json")
resp, err := http.DefaultClient.Do(req)

if err != nil {
return nil, err
}

body, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}

str := string(body[:])
fmt.Print(str)

v := RpcResponse{Payload: payload}
json.Unmarshal(body, &v)

return &v,nil
}

func Rpc(name string, data interface{}, payload interface{}) (*RpcResponse, error) {
url := defaultRpcConf.String("urls::test")
requestJson, err := json.Marshal(data)
if err != nil {
return nil, err
}
p, e := Request(url, bytes.NewReader(requestJson), &payload)
if e != nil {
return nil, e
}
return p, nil
}

//rpc 简单调用方法
func RpcWithPayload(name string, data interface{}, payload interface{}) error {
p, e := Rpc(name, data, payload)

if e != nil {
return e
}

//检查rpc返回状态码
if p.Code != "0" {
return errors.New("error code: " + p.Code + " Message: " + p.Message)
}

return nil
}

func init() {
conf, err := config.NewConfig("ini", "../conf/rpc.conf")
if err != nil {
panic(err)
}
defaultRpcConf = conf
}


安装官方教程安装cronbot命令。

常见问题：

Q1：No module named ‘requests.packages.urllib3’
请使用 (pip install requests urllib3 –force –upgrade)升级urllib3版本既可解决。
Q2：ImportError: ‘pyOpenSSL’ module missing required functionality. Try upgrading to v0.14 or newer.
请使用 (pip uninstall pyOpenSSL; pip install pyOpenSSL==16.2.0) 安装16.2.0版本的pyOpenSSL才可以，最新的17.0还是会出现报错

该脚本的前提是在　~/.ssh/config 已经配置好的情况下使用

#!/bin/bash
#####################################################################
########    服务器批量操作脚本
########    Email: i@liufang.org.cn
#####################################################################
for host in `cat ~/.ssh/config |grep 'Host '|awk -F ' ' '{print $2}'`
do
	echo -e "\033[34m\r\nexec command:$1 at host $host \033[0m"
	ssh $host $@
done

在国内如果没拉专线大部分都是很慢很慢， 无法正常使用docker, 但是我们可以通过镜像地址来减轻这种现象。

配置信息（/etc/default/docker）：

# Docker Upstart and SysVinit configuration file

#
# THIS FILE DOES NOT APPLY TO SYSTEMD
#
#   Please see the documentation for "systemd drop-ins":
#   https://docs.docker.com/engine/admin/systemd/
#

# Customize location of Docker binary (especially for development testing).
#DOCKERD="/usr/local/bin/dockerd"

# Use DOCKER_OPTS to modify the daemon startup options.
#DOCKER_OPTS="--dns 8.8.8.8 --dns 8.8.4.4"
#阿里云镜像
DOCKER_OPTS="--registry-mirror=https://4xle30hc.mirror.aliyuncs.com"
#官方中国镜像
#DOCKER_OPTS="--registry-mirror=https://registry.docker-cn.com"
#163镜像
#DOCKER_OPTS="--registry-mirror=http://hub-mirror.c.163.com"

# If you need Docker to use an HTTP proxy, it can also be specified here.
#export http_proxy="http://127.0.0.1:3128/"

# This is also a handy place to tweak where Docker's temporary files go.
#export DOCKER_TMPDIR="/mnt/bigdrive/docker-tmp"

修改配置后请重启docker服务：

sudo service docker restart