github.com/nacos-group/nacos-sdk-go v1.0.7

经过无数次的尝试,发现魔改后的nacos-spring 用go注册会提示重试三次都失败，失败内容如下:

call domain error:<request return error code 400> , result:<caused: Param 'serviceName' is required.;>

后来采用nacos docker搭建nacos注册中心可正常与spring项目通讯,至于加密通讯方面可能需要自己动手，先上go代码

nacos工具类:

package client

import (
    "fmt"
    "github.com/nacos-group/nacos-sdk-go/clients"
    "github.com/nacos-group/nacos-sdk-go/clients/config_client"
    "github.com/nacos-group/nacos-sdk-go/clients/naming_client"
    "github.com/nacos-group/nacos-sdk-go/common/constant"
    "github.com/nacos-group/nacos-sdk-go/model"
    "github.com/nacos-group/nacos-sdk-go/vo"

    "strings"
)

type NacosClient struct {
    Client config_client.IConfigClient
    NamingClient naming_client.INamingClient
}
//创建nacos客户端
func NewNacos(option *Options,isJwt bool) *NacosClient {
    var clientConfig constant.ClientConfig
    if isJwt {
        clientConfig = constant.ClientConfig{
            TimeoutMs:      option.TimeoutMs,
            BeatInterval:   option.BeatInterval,
            LogDir:"/tmp/nacos/log",
            CacheDir:"/tmp/nacos/cache",
            LogLevel:"debug",
            //NamespaceId:"public",
            //AppName:"unknown",
            //OpenKMS:true,
            //Username:"nacos",
            //Password:"$2a$10$EuWPZHzz32dJN7jexM34MOeYirDdFAZm2kuWj7VEOJhhZkDrxfvUu",
            //AccessKey:"pigx",
            //SecretKey:"PBEWithMD5AndDES",
        }
    }else {
        clientConfig = constant.ClientConfig{
            TimeoutMs:      option.TimeoutMs,
            BeatInterval:   option.BeatInterval,
            LogDir:"/tmp/nacos/log",
            CacheDir:"/tmp/nacos/cache",
            LogLevel:"debug",
        }
    }

    serverConfigs := []constant.ServerConfig{
        *constant.NewServerConfig(
            option.Address,
            option.Port,
            constant.WithContextPath("/nacos")),
    }
    // Create Config Center
    client, err := clients.NewConfigClient(vo.NacosClientParam{
        ClientConfig:  &clientConfig,
        ServerConfigs: serverConfigs,
    })
    if err != nil {
        panic(err)
    }
    // Create Register Center
    namingClient,err:=clients.NewNamingClient(vo.NacosClientParam{
        ClientConfig:  &clientConfig,
        ServerConfigs: serverConfigs,
    })
    if err!=nil{
        panic(err)
    }
    return &NacosClient{Client: client,NamingClient: namingClient}
}
//项目公有配置
func (c *NacosClient) Publish(dataId, group, content string) bool {
    ok, err := c.Client.PublishConfig(vo.ConfigParam{
        DataId:  dataId,
        Group:   group,
        Content: content,
    })
    if err != nil {
        return false
    }
    return ok
}
//获取配置文件
func (c *NacosClient) Get(dataId, group string) string {
    s, err := c.Client.GetConfig(vo.ConfigParam{
        DataId: dataId,
        Group:  group,
    })
    if err != nil {
        return ""
    }
    return s
}
//删除nacos配置
func (c *NacosClient) Delete(dataId, group string) bool {
    ok,err:=c.Client.DeleteConfig(vo.ConfigParam{
        DataId:   dataId,
        Group:    group,
    })
    if err!=nil{
        return false
    }
    return ok
}
//监听nacos配置文件变动
func (c *NacosClient) Listen(dataId, group string,OnChange func(namespace, group, dataId, data string)) error {
    return c.Client.ListenConfig(vo.ConfigParam{
        DataId:   dataId,
        Group:    group,
        OnChange: OnChange,
    })
}
//注册到nacos服务
func (c *NacosClient) Register(ip string,port uint64,name string) bool {
    ok,err:=c.NamingClient.RegisterInstance(vo.RegisterInstanceParam{
        Ip:          ip,
        Port:        port,
        ServiceName: name,
        Weight:      1.0,
        //Metadata: ,
        GroupName:  "",
        Enable:      true,
        Healthy:     true,
        Ephemeral:   true,
    })
    if err!=nil{
        fmt.Printf("注册失败:%v",err)
        return false
    }
    return ok
}
//注销nacos服务
func (c *NacosClient) Deregister(ip string,port uint64,name string) bool {
    ok ,err:=c.NamingClient.DeregisterInstance(vo.DeregisterInstanceParam{
        Ip:          ip,
        Port:        port,
        ServiceName: name,
        //Cluster:     "a",
        Ephemeral:   true,
    })
    if err!=nil{
        return false
    }
    return ok
}
//获取nacos服务信息
func (c *NacosClient) GetService(name string) (model.Service,error) {
    return c.NamingClient.GetService(vo.GetServiceParam{
        //Clusters:    []string{"a"},
        ServiceName: name,
    })
}
//获取一个健康的实例（加权随机轮询）
func (c *NacosClient) SelectOneHealthyInstance(name string) (*model.Instance,error) {
    return c.NamingClient.SelectOneHealthyInstance(vo.SelectOneHealthInstanceParam{
        ServiceName: name,
        //Clusters:    []string{"a"},
    })
}

实体

package client

type Options struct {
    TimeoutMs      uint64 //请求Nacos服务端的超时时间，默认是10000ms
    BeatInterval   int64  //发送到服务的心跳时间 默认5000ms
    Address        string //注册中心地址
    Port           uint64 //注册中心端口
}
func deafultOptions() *Options {
    return &Options{
        TimeoutMs:      10*1000,
        ListenInterval: 3*1000,
        BeatInterval:   5*1000,
    }
}
func (option *Options) WithAdress(address string) *Options {
    option.Address = address
    return option
}
func (option *Options) WithPort(port uint64) *Options {
    option.Port = port
    return option
}
func NewOption() *Options {
    return deafultOptions()
}

从nacos读取配置文件方法

option:=client.NewOption().WithAdress(nacosIp).WithPort(8848) //nacosIp 注册中心ip
nacosClient:=client.NewNacos(option,false)
content:=nacosClient.Get(global.GVA_DATA_ID,global.GVA_GROUP) //global.GVA_DATA_ID nacos中的配置文件明  global.GVA_GROUP分组

注册服务到注册中心方法

option:=client.NewOption().WithAdress(nacosIp).WithPort(port)  //注册中心和端口
nacosClient:=client.NewNacos(option,true)
if ok :=nacosClient.Register(localhostip,iport,serverName);ok{  //本机ip 本机端口  本服务名称
     //注册成功逻辑处理
}

module.exports = {
    region: 'oss-cn-hongkong',  // 例如：oss-cn-hangzhou
    accessKeyId: 'xxxx',
    accessKeySecret: 'xxx',
    bucket: 'xxx'
}

然后在vue.config.js导入相关包文件

const WebpackAliyunOss = require("webpack-aliyun-oss"); // 引入webpack-aliyun-oss,如果找不到包，就先npm安装
const Oss = require('./oss.config.js');//阿里云配置文件

在configureWebpack中如下修改,在该方法内可以自行添加环境判断

configureWebpack: config=>{
   let webpackAliyunOss = [
                new WebpackAliyunOss({
                    from: ['./dist/**'], // 上传那个文件或文件夹  可以是字符串或数组
                    dist: "/",  // 需要上传到oss上的给定文件目录
                    region: Oss.region,
                    accessKeyId: Oss.accessKeyId,
                    accessKeySecret: Oss.accessKeySecret,
                    bucket: Oss.bucket,

                    // test: true,
                    //上面一行，可以在进行测试看上传路径是否正确, 打开后只会显示上传路径并不会真正上传;

                    // 因为文件标识符 "\"  和 "/" 的区别 不进行 setOssPath配置,上传的文件夹就会拼到文件名上, 丢失了文件目录,所以需要对setOssPath 配置。
                    setOssPath: filePath => {
                        // some operations to filePath
                        let index = filePath.lastIndexOf("dist");
                        let Path = filePath.substring(index + 4, filePath.length);
                        return Path.replace(/\\/g, "/");
                    },
                    setHeaders: filePath => {
                        // some operations to filePath
                        // return false to use default header
                        return {
                            "Cache-Control": "max-age=31536000"
                        };
                    }
                })
            ];
            config.plugins = [...config.plugins, ...webpackAliyunOss ];
 }

下载aliossUploader放入controller中

region为阿里oss节点，bucket为存储

PC端搜索 image:function(i){ 下面代码放到后方

layui.use("aliossUploader",function(){var a=layui.aliossUploader,e=i.data("type")||"images",n=_();a.render({elm:i.find("input")[0],region:"oss-cn-hongkong",bucket:"xxxx",layerTitle:"上传图片",accessidFiled:"accessid",policyFiled:"policy",signatureFiled:"signature",policyData:{},policyHeader:{Authorization:"Bearer "+layui.data(layui.setter.tableName).Authorization},policyUrl:"/rg/rgaccount/getOss",fileType:"images",multiple:!1,httpStr:"http",prefixPath:"rgAccQrUrlDir/",allUploaded:function(i){console.log("上传响应",i),"images"===e?ai(n.textarea[0],"img["+(i[0].ossUrl||"")+"]"):"file"===e&&ai(n.textarea[0],"file("+(i[0].ossUrl||"")+")["+(i.data.name||"下载文件")+"]"),_()},policyFailed:function(i){t.msg(i.msg||"上传失败")}})})}

手机端搜索 image:function(i){ 下面代码放到后方

layui.use("aliossUploader",function(){var e=layui.aliossUploader,a=i.data("type")||"images",t=T();e.render({elm:i.find("input")[0],region:"oss-cn-hongkong",bucket:"xxxx",layerTitle:"上传图片",accessidFiled:"accessid",policyFiled:"policy",signatureFiled:"signature",policyData:{},policyUrl:"/rg/rgaccount/getOss",fileType:"images",multiple:!1,httpStr:"http",prefixPath:"rgAccQrUrlDir/",allUploaded:function(i){console.log("上传响应",i),"images"===a?P(t.textarea[0],"img["+(i[0].ossUrl||"")+"]"):"file"===a&&P(t.textarea[0],"file("+(i[0].ossUrl||"")+")["+(i[0].name||"下载文件")+"]"),I()},policyFailed:function(i){layer.msg(i.msg||"上传失败")}})})}

使用brew 安装lrzsz

终端输入brew install lrzsz，如果没有安装homeBrew需要先安装

安装完成后检查 ls -alh /usr/local/bin/sz 是否存在

修改iterm2的配置：

打开iterm2

同时按 command和,键 ------- Profiles ------  Default ---- Advanced ----- Triggers的Edit按钮

下载 http://file.zk1006.cn/mac/iterm-lrszs.zip

解压至/usr/local/bin/并赋执行权限

添加如下trigger

Regular expression: \*\*B0100

Action: Run Silent Coprocess

Parameters: /usr/local/bin/iterm2-send-zmodem.sh

Regular expression: \*\*B00000000000000

Action: Run Silent Coprocess

Parameters: /usr/local/bin/iterm2-recv-zmodem.sh

curl -Lo install.sh https://raw.githubusercontent.com/ohmyzsh/ohmyzsh/master/tools/install.sh
sh install.sh

切换当前默认shell

chsh -s /bin/zsh

重新打开终端即可生效

zsh的配置文件在~/.zshrc

1.搜罗一大堆最终指向这是http2本身的bug。

解决方式

1.(推荐)直接换掉Git的http版本

git config --global http.version HTTP/1.1

2.更改Git的http克隆为ssh，使用ssh进行提交和拉取代码

附：使用ssh连接Git操作指南

其他网上方式我也均有试过，但是都治标不治本。

1. 更改http buffer，第一次还有用，后面也歇菜了。

git config --global http.postBuffer 524288000

2.重新克隆，好了几天，也完蛋了。尤其是合并别人大量代码之后立马就会出现

docker run -d --restart=always --name zookeeper --volume /etc/localtime:/etc/localtime -p 2181:2181 -p 2888:2888 -p 3888:3888 -t zookeeper

再安装kafka

docker run -d --name kafka --publish 9092:9092 \
--link zookeeper \
--env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181 \
--env KAFKA_ADVERTISED_HOST_NAME=192.168.1.22 \
--env KAFKA_ADVERTISED_PORT=9092 --restart=always \
--volume /etc/localtime:/etc/localtime \
wurstmeister/kafka

192.168.1.22为访问地址

下面为application.yml关于kafka配置

kafka:
  producer:
retries: 1
servers: 192.168.1.22:9092
linger: 1
batch:
  size: 4096
buffer:
  memory: 40960

  consumer:
auto:
  offset:
reset: latest
  commit:
interval: 100
servers: 192.168.1.22:9092
session:
  timeout: 20000
enable:
  auto:
commit: true
concurrency: 10
group:
  id: ${spring.application.name}-group

java消费者配置类

@Configuration
@EnableKafka
public class KafkaConsumerConfig {

    @Value("${kafka.consumer.servers}")
    private String servers;
    @Value("${kafka.consumer.enable.auto.commit}")
    private boolean enableAutoCommit;
    @Value("${kafka.consumer.session.timeout}")
    private String sessionTimeout;
    @Value("${kafka.consumer.auto.commit.interval}")
    private String autoCommitInterval;
    @Value("${kafka.consumer.group.id}")
    private String groupId;
    @Value("${kafka.consumer.auto.offset.reset}")
    private String autoOffsetReset;
    @Value("${kafka.consumer.concurrency}")
    private int concurrency;
    @Bean
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory());
        factory.setConcurrency(concurrency);
        factory.getContainerProperties().setPollTimeout(1500);
        return factory;
    }
    public ConsumerFactory<String, String> consumerFactory() {
        return new DefaultKafkaConsumerFactory<>(consumerConfigs());
    }
    public Map<String, Object> consumerConfigs() {
        Map<String, Object> propsMap = new HashMap<>(8);
        propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
        propsMap.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, enableAutoCommit);
        propsMap.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, autoCommitInterval);
        propsMap.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, sessionTimeout);
        propsMap.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        propsMap.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
        propsMap.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
        propsMap.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, autoOffsetReset);
        return propsMap;
    }
}

java生产者配置类

@Configuration
@EnableKafka
public class KafkaProducerConfig {
@Value("${kafka.producer.servers}")
private String servers;
@Value("${kafka.producer.retries}")
private int retries;
@Value("${kafka.producer.batch.size}")
private int batchSize;
@Value("${kafka.producer.linger}")
private int linger;
@Value("${kafka.producer.buffer.memory}")
private int bufferMemory;
@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
return new KafkaTemplate(producerFactory());
}
public ProducerFactory<String, String> producerFactory() {
return new DefaultKafkaProducerFactory<>(producerConfigs());
}
public Map<String, Object> producerConfigs() {
Map<String, Object> props = new HashMap<>();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, servers);
props.put(ProducerConfig.RETRIES_CONFIG, retries);
props.put(ProducerConfig.BATCH_SIZE_CONFIG, batchSize);
props.put(ProducerConfig.LINGER_MS_CONFIG, linger);
props.put(ProducerConfig.BUFFER_MEMORY_CONFIG, bufferMemory);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
return props;
}
}
发送kafka消息类

@Component
@Slf4j
public class KafkaMessageProducer {

   @Resource
   KafkaTemplate kafkaTemplate;

   /**
    * 发送消息
    *
    * @param message
    */
   public void sendMessage(ProducerMessage message) {
      log.info("kafka 请求参数:[{}]", JsonUtils.toJSONString(message));
      try {
         if (StringUtils.isNotBlank(message.getKey())) {
            this.kafkaTemplate.send(message.getTopic(), message.getKey(), message.getBody());
         } else {
            this.kafkaTemplate.send(message.getTopic(), message.getBody());
         }
      } catch (Exception e) {
         log.error("发送kafka异常:[{}]", message, e.getMessage(), e);
      }
      log.info("kafka response:[{}]", message);
   }
}

接受kafka消息

@KafkaListener(topics = {Constants.CREATE_ORDER_DELIVERY_TOPIC})
public void createReceivingAddress(String message){
   log.info("CREATE_ORDER_DELIVERY_TOPIC kafak message:{[]}",message);
   ReceivingAddress receivingAddress = JsonUtils.parseObject(message,ReceivingAddress.class);
   if(receivingAddress!=null){
      ReceivingAddress receivingAddressOld = receivingAddressService.findOneByEntity(receivingAddress);
      if(receivingAddressOld==null){
         receivingAddress.setStatus(DeliveryStatus.TO_BE_PAID);
         receivingAddressService.create(receivingAddress);
         return;
      }else{
         log.error("已存在订单:{[]}",JsonUtils.toJSONString(receivingAddressOld));
      }
   }else{
      log.error("CREATE_ORDER_DELIVERY_TOPIC kafka 消息异常");
   }
}

• • • • • command
          星号分别为：分 时 日 月 周
          特殊的符号就是* / - ：

代表所有的取值范围内的数字
/ 代表每的意思
/5 表示每5个单位
-代表从某个数字到某个数字
,分开几个离散的数字

例子
0 3 * /root/test.sh 每天凌晨3点执行test.sh文件

• 23-7/1 /root/lnmp restart 晚上11点到早上7点之间，每隔一小时重启lnmp套件
  /30 /usr/sbin/ntpdate 每半小时同步一下时间
  0 23 6 /lnmp restart 每星期六的11 : 00 pm重启重启lnmp套件。
  /1 * echo “i am running.”>>/tmp/running.txt 每隔1分钟向/tmp/running.txt写一个”i am running.”字符串

定时服务操作
启动

/etc/init.d/cron start

关闭

/etc/init.d/cron stop

重启

/etc/init.d/cron restart

定时主文件目录：/etc/crontab
根据用户所执行的定时设置目录：/var/spool/cron/crontabs/
关联定时任务 crontab filename

crontab -u //设定某个用户的cron服务，一般root用户在执行这个命令的时候需要此参数
crontab -l //列出某个用户cron服务的详细内容
crontab -r //删除每个用户的cron服务
crontab -e //编辑某个用户的cron服务

pom.xml中配置如下

<dependency>
    <groupId>org.seleniumhq.selenium</groupId>
    <artifactId>selenium-java</artifactId>
    <version>3.141.59</version>
</dependency>

java代码如下

private ChromeOptions options = new ChromeOptions();
private ChromeDriver webDriver;

/**
 * 创建浏览器驱动和打开一个浏览器窗口
 * @return
 */
private ChromeDriver getChromeDriver(){
    this.options.addArguments("--incognito");
    List excludeSwitches=new ArrayList<String>();
    Map<String, Object> prefs = new HashMap<String, Object>();
    prefs.put("profile.managed_default_content_settings.images", 2);
    excludeSwitches.add("enable-automation");
    this.options.setExperimentalOption("excludeSwitches",excludeSwitches);
    this.options.setExperimentalOption("prefs",prefs);

    File file = new File(System.getProperty("user.dir") + "\\Google\\Chrome\\Application\\chromedriver.exe");
    if (file.exists()) {
        System.setProperty("webdriver.chrome.driver", file.getAbsolutePath());
    } else {
        System.setProperty("webdriver.chrome.driver", dir);
    }
    log.info("当前读取驱动路径:{}", System.getProperty("webdriver.chrome.driver"));

    return new ChromeDriver(this.options);
}

webdriver.chrome.driver用于指定谷歌浏览器驱动路径

--incognito参数为隐身模式打开浏览器

profile.managed_default_content_settings.images参数为无图模式

enable-automation参数为屏蔽浏览器自动化控制提示(有部分网站会检测当前页面是否为自动化控制,请勿关闭右上角提示,否则会失效)

打开指定网站

this.webDriver.get("https://baidu.com");
获取当前浏览器打开的所有页面元素

this.webDriver.getPageSource();