发表于
字数统计: 380 字 | 阅读时长 ≈ 1 min

电池损耗

1.打开命令终端

点击底部栏 Windows图标，选择“Windows系统”中的“命令提示符”
右键以管理员身份运行

2.输入命令

进入命令符对话框后可输入命令

1
powercfg /batteryreport /output "C:\battery_report.html"

注意的一点是，符号需要是英文格式，并且中间拥有空格，否则提示：参数无效，无法操作识别等情况发生。

2.查看

提示操作成功后，进入电脑找到保存路径 C:\ ，可发现新增【battery_report.html】网页文件。

可了解到电池基本概况：
电脑名称、系统名称、保存时间等；
当前状态下的电池容量概况；
可以看到近三天的电池充电情况；
详细时间段的电池使用记录；

磁盘速度

1.打开命令终端

点击底部栏 Windows图标，选择“Windows系统”中的“命令提示符”
右键以管理员身份运行

2.输入命令

进入命令符对话框后可输入命令

1
winsat disk -ran -write –drive c

即可查看磁盘c的速度，若若需要查看其他盘的速度将后面的“c” 改为其他盘即可 

1
winsat disk -ran -write –drive d

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 401 字 | 阅读时长 ≈ 2 min

简介

instantbox是一款非常实用的项目，它能够让你在几秒内启动一个主流的 Linux 系统，随起随用，支持 Ubuntu, CentOS, Arch Linux, Debian, Fedora 和 Alpine，通过 WebShell 访问，简单快捷，适合于演示、测试、体验等场合。

环境

安装 Docker
安装 Docker 与 Docker-Com­pose

1
2
3
4
5
6
7
8
curl -fsSL https://get.docker.com | bash -s docker
curl -L "https://github.com/docker/compose/releases/download/1.29.2/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose
chmod +x /usr/local/bin/docker-compose
systemctl start docker
systemctl enable docker
``` 
##  安装instantbox
使用 Docker-Compose，则可以直接下载 docker-compose 文件，并跳过安装脚本。

wget https://raw.githubusercontent.com/instantbox/instantbox/master/docker-compose.yml

1
修改 docker-compose.yml 中SERVERURL，和对外访问的端口

version: ‘3’

services:
server:
image: instantbox/instantbox:latest
container_name: instantbox_server
volumes:
- /var/run/docker.sock:/var/run/docker.sock
environment:
- SERVERURL=<替换为服务器的IP>
networks:
- instantbox_net

frontend:
image: instantbox/instantbox-frontend:latest
container_name: instantbox_frontend
links:
- server
ports:
- <替换为端口>:80
networks:
- instantbox_net

cron:
image: instantbox/cron:latest
container_name: instantbox_cron
links:
- frontend
environment:
- CRON_STRINGS=* * * * * wget -qO /dev/null http://frontend/api/v2/superinspire/prune
networks:
- instantbox_net

networks:
instantbox_net:

1
2

现在运行：

docker-compose up -d

```
Docker 将下载最新的 Instantbox 映像，
使用 Instantbox 在浏览器中访问 Linux 发行版
如果从同一本地网络上的另一台计算机访问，则需要查找主机的本地 IP 地址。

访问IP:端口

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 896 字 | 阅读时长 ≈ 4 min

一、Linux上卸载JDK

1. Linux删除自带的jdk

在我们安装linux虚拟机时可能会自带安装一个jdk，这时候如果想要干净方便的删除jdk的话可用以下方法

第一步 ：先查看自带的jdk有几个，用命令：

1
rpm -qa | grep -i java

意思是查询所安装的带有java的rpm软件包。

第二步：去删除，命令如下：

1
rpm -qa | grep -i java | xargs -n1 rpm -e --nodeps

解释：
rpm -qa:查询所安装的所有rpm包
grep -i:忽略大小写
xargs -n1:表示每次只传递一个参数
rpm -e –nodeps:强制卸载软件

第三步：编辑profile文件，去除环境变量配置

vim /etc/profile

#然后 source命令让修改后的profile文件立即生效
source /etc/profile

最后：
可以再用命令： 查看是否还在即可

1
rpm -qa | grep -i java

或者查看java版本

1
java -version

2. Linux上卸载自己安装的JDK

1.先 查看是否安装了JDK

1
java -version

2.查看jdk安装的路径

1
which java

3.卸载命令rm -rf JDK地址，比如

1
rm -rf /usr/java/jdk1.8.0_181/

4.进去/usr/java目录查看一下，ls是显示目录下文件，发现确实什么都没有了

5.接下来删除环境变量，装的时候环境变量都是在/etc/profile下面的，进入profile，把之前配置的java相关的环境变量全给删除

1
vim /etc/profile

之后 让配置文件生效。

1
source /etc/profile

二、安装jdk1.8

第一步：创建jdk安装目录(该/usr/local/src 目录是空的,最好把我们自己下载的放到这,容易区分)

1
mkdir -p /usr/local/src/jdk

第二步：查看安装程序

1
rpm -qa | grep -i jdk

若之前安装过jdk，下次安装一定把之前的删除干净

第三步：命令下载jdk包 （需要联网，下载也需要点时间）
官网下载页面：Java Downloads | Oracle

本章使用的为后缀为tar.gz的文件（不需要安装），如jdk-8u221-linux-x64.tar.gz

1
wget -O jdk-8u221-linux-x64.tar.gz https://download.oracle.com/otn/java/jdk/8u221-b11/230deb18db3e4014bb8e3e8324f81b43/jdk-8u221-linux-x64.tar.gz?AuthParam=1565847915_b5885c839380ee62ab06bf97bdb1f2c7

注意：如果上面wget命令不能用,报错：-bash: wget: command not found。执行一下该命令(安装依赖包) yum -y install wget

第四步：解压

1
tar -zxvf jdk-8u221-linux-x64.tar.gz -C /usr/local

系统会生成一个名为：jdk1.8.0_221 的文件夹。-C 指定安装到/usr/local 目录下

第五步：配置环境变量

1
vim /etc/profile

可以看到这个文件的内容，profile文件有点类似于windows系统里面的环境变量的配置，

shift + g 定位到最后一行

这个时候按一下a或i键，进入编辑模式

需要加的( JAVA_HOME 是jdk安装目录，和在Windows下配置一样 )

1
2
3
export JAVA_HOME=/usr/local/jdk1.8.0_221
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tool.jar

第六步：退出文件，保存
按Esc键 输入:wq 保存并退出

第七步：让配置文件生效

1
source /etc/profile

第八步：查看是否配置成功

1
java -version

若出现jdk版本号，则安装并配置环境变量成功

如果提示命令找不到的话，查看一下jdk的配置路径是否错误。

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 828 字 | 阅读时长 ≈ 4 min

1.说明

Spring可以方便的集成使用 Kafka消息队列 ，
只需要引入依赖包spring-kafka,
注意版本兼容问题，
本文详细介绍SpringBoot集成Kafka的方法，
以及生产者和消费者的使用方法。

2.引入依赖

在 pom.xml 中引入Spring Kafka版本：

1
2
3
4
<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
</dependency>

3.配置

新增applicaion.yml如下配置：

Spring Kafka 通用配置

1
2
3
4
spring:
  kafka:
    # kafka连接接地址
    bootstrap-servers: localhost:9092

通用配置：spring.kafka.*
下面的admin、producer、consumer、streams配置，
会覆盖通用配置 spring.kafka.* 中相同的属性。

生产者配置

1
2
3
4
5
6
7
8
spring:
  kafka:
    # 生产者配置
    producer:
      # 序列化key的类
      key-serializer: org.apache.kafka.common.serialization.StringSerializer 
      # 反序列化value的类
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer

生产者相关配置：spring.kafka.producer.*

消费者配置

1
2
3
4
5
6
7
8
9
10
spring:
  kafka:
    # 消费者配置    
    consumer:
      # 消费者所属消息组
      group-id: testGroup 
      # 反序列化key的类
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer 
      # 反序列化value的类  
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer

消费者相关配置：spring.kafka.consumer.*

默认 value-deserializer 使用 org.apache.kafka.common.serialization.StringDeserializer ，
只支持文本消息。
使用org.springframework.kafka.support.serializer.JsonDeserializer可以让消息支持JSON。

完整applicaion.yml配置：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
server:
  port: 8028 

spring:
  kafka:
    # kafka连接接地址
    bootstrap-servers: localhost:9092
    # 生产者配置
    producer:
      # 序列化key的类
      key-serializer: org.apache.kafka.common.serialization.StringSerializer 
      # 反序列化value的类
      value-serializer: org.springframework.kafka.support.serializer.JsonSerializer 
    # 消费者配置    
    consumer:
      # 消费者所属消息组
      group-id: testGroup 
      # 反序列化key的类
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer 
      # 反序列化value的类  
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer

4.开发代码

KafkaMQApplication.java启动类，

注意要新增 @EnableKafka 注解:

1
2
3
4
5
6
7
8
9
10
11
12
13
package com.yuwen.spring.kafka;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.kafka.annotation.EnableKafka;

@SpringBootApplication
@EnableKafka
public class KafkaMQApplication {
    public static void main(String[] args) {
        SpringApplication.run(KafkaMQApplication.class, args);
    }
}

生产者发送消息

Spring Kafka 提供KafkaTemplate类发送消息，
在需要的地方注入即可，
新增ProviderService.java生产者服务类：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
package com.yuwen.spring.kafka.provider;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Service;

@Service
public class ProviderService {
    public static final String TOPIC = "testTopic";

    @Autowired
    private KafkaTemplate<?, String> kafkaTemplate;

    public void send(String message) {
        // 发送消息
        kafkaTemplate.send(TOPIC, message);
        System.out.println("Provider= " + message);
    }
}

注意指定 topic ，
以及要发送的消息内容message。

消费者接收消息

新增ConsumerService.java类，
注意使用 @KafkaListener 注解：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
package com.yuwen.spring.kafka.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

import com.yuwen.spring.kafka.provider.ProviderService;

@Service
public class ConsumerService {
    @KafkaListener(topics = ProviderService.TOPIC, groupId = "testGroup", topicPartitions = {})
    public void receive(String message) {
        System.out.println("Consumer= " + message);
    }
}

参数说明：
topics 与发送消息topic相同，可以指定多个
groupId 消费组唯一id
topicPartitions topic分区，可指定多个

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 384 字 | 阅读时长 ≈ 2 min

kafka-compose.yml 文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
#docker-compose -f kafka-compose.yml up -d
#kafka-compose.yml 配置文件如下  
version: '3'
services:
  kafka:
    container_name: kafka
    image: wurstmeister/kafka:2.13-2.6.0
    ports:
      - "9092:9092"
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_HOST_NAME: 192.168.23.128 # need to be replaced with host ip 替换为宿主机IP
      advertised.listeners: PLAINTEXT://192.168.23.128:9092 # need to be replaced with host ip 替换为宿主机IP
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock # 容器内可以执行docker ps、docker port等命令
    restart: always

  zookeeper:
    container_name: zookeeper
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
    restart: always

注意:
1.KAFKA_ADVERTISED_HOST_NAME 替换为宿主机IP
2.advertised.listeners 替换为宿主机IP
3.此镜像版本，kafka默认占用1G内存，若启动不了，请检查内存足够

kafkaui-compose.yml 文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
#docker-compose -f kafkaui-compose.yml up -d
#kafkaui-compose.yml 配置文件如下  
version: '3.0'
services:
  kafka-ui:
    image: provectuslabs/kafka-ui:master
    container_name: kafka-ui
    ports:
      - 18080:8080
    restart: always
    environment:
      - KAFKA_CLUSTERS_0_NAME=douyh
      - KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS=192.168.23.128:9092
      # - KAFKA_CLUSTERS_0_PROPERTIES_SECURITY_PROTOCOL=SASL_PLAINTEXT
      # - KAFKA_CLUSTERS_0_PROPERTIES_SASL_MECHANISM=PLAIN
      # - KAFKA_CLUSTERS_0_PROPERTIES_SASL_JAAS_CONFIG=org.apache.kafka.common.security.plain.PlainLoginModule required username="app" password="xxxxxxxx";
      # - KAFKA_CLUSTERS_0_PROPERTIES_PROTOCOL=SASL
      - AUTH_TYPE="LOGIN_FORM"
      - SPRING_SECURITY_USER_NAME=root
      - SPRING_SECURITY_USER_PASSWORD=root

注意:
1.KAFKA_CLUSTERS_0_BOOTSTRAPSERVERS 替换为宿主机IP

在外部浏览器可以访问 http://ip:18080/
账号:root,
密码:root

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 1,002 字 | 阅读时长 ≈ 5 min

一、引入jar包

pom.xml中增加一下以来

1
2
3
4
5
6
7
8
9
10
11
12
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-integration</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mqtt</artifactId>
</dependency>

二、增加配置

applicaion.yml配置如下

1
2
3
4
5
6
7
8
9
spring:
  mqtt:
    username: admin							# 账号
    password: public						# 密码
    host-url: tcp://ip:1883		            # mqtt连接tcp地址
    client-id: test							# 客户端Id，每个启动的id要不同
    default-topic: test						# 默认主题
    timeout: 100							# 超时时间
    keepalive: 100							# 保持连接数

三、mqtt配置类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
import lombok.Data;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

/**
 * @Classname MtqqEntity
 * @Description mqtt相关配置信息
 */
@Component
@ConfigurationProperties("spring.mqtt")
@Data
public class MqttConfig {
    @Autowired
    private MqttPushClient mqttPushClient;

    /**
     * 用户名
     */
    private String username;
    /**
     * 密码
     */
    private String password;
    /**
     * 连接地址
     */
    private String hostUrl;
    /**
     * 客户Id
     */
    private String clientId;
    /**
     * 默认连接话题
     */
    private String defaultTopic;
    /**
     * 超时时间
     */
    private int timeout;
    /**
     * 保持连接数
     */
    private int keepalive;

    @Bean
    public MqttPushClient getMqttPushClient() {
        mqttPushClient.connect(hostUrl, clientId, username, password, timeout, keepalive);
        // 以/#结尾表示订阅所有以test开头的主题
        mqttPushClient.subscribe("test/#", 0);
        return mqttPushClient;
    }
}

四、mqtt推送客户端

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @Classname MqttPushClient
 * @Description mqtt推送客户端 
 */
@Component
@Slf4j
public class MqttPushClient {

    @Autowired
    private PushCallback pushCallback;

    public static MqttClient client;

    public static MqttClient getClient() {
        return client;
    }

    private static void setClient(MqttClient client) {
        MqttPushClient.client = client;
    }

    /**
     * 客户端连接
     *
     * @param host      ip+端口
     * @param clientID  客户端Id
     * @param username  用户名
     * @param password  密码
     * @param timeout   超时时间
     * @param keepalive 保留数
     */
    public void connect(String host, String clientID, String username, String password, int timeout, int keepalive) {
        MqttClient client;
        try {
            client = new MqttClient(host, clientID, new MemoryPersistence());
            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);
            options.setUserName(username);
            options.setPassword(password.toCharArray());
            options.setConnectionTimeout(timeout);
            options.setKeepAliveInterval(keepalive);
            MqttPushClient.setClient(client);
            try {
                client.setCallback(pushCallback);
                client.connect(options);
            } catch (Exception e) {
                e.printStackTrace();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    /**
     * 订阅某个主题
     *
     * @param topic 主题
     * @param qos   连接方式
     */
    public void subscribe(String topic, int qos) {
        log.info("开始订阅主题" + topic);
        try {
            MqttPushClient.getClient().subscribe(topic, qos);
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

五、消费监听类

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * @Classname PushCallback
 * @Description 消费监听类 
 */
@Component
@Slf4j
public class PushCallback implements MqttCallback {

    @Autowired
    private MqttConfig mqttConfig;


    @Override
    public void connectionLost(Throwable throwable) {
        // 连接丢失后，一般在这里面进行重连
        log.info("连接断开，可以做重连");
        if (MqttPushClient.client == null || !MqttPushClient.client.isConnected()) {
            mqttConfig.getMqttPushClient();
        }
    }

    @Override
    public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception {
        // subscribe后得到的消息会执行到这里面
        log.info("接收消息主题 : " + topic);
        log.info("接收消息Qos : " + mqttMessage.getQos());
        log.info("接收消息内容 : " + new String(mqttMessage.getPayload()));
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
        log.info("deliveryComplete---------" + iMqttDeliveryToken.isComplete());
    }
}

六、测试文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
import com.wang.emqtt.config.MqttPushClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

/** 
 * @Description: 测试文件
 */
@RestController
@RequestMapping("/")
public class TestController {

    @Autowired
    private MqttPushClient mqttPushClient;

    @GetMapping(value = "/publishTopic")
    public String publishTopic() {
        mqttPushClient.publish(0,false,"test/test","测试一下发布消息");
        return "RUtils.ok()";
    }
}

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 257 字 | 阅读时长 ≈ 1 min

emqtt-compose.yml 文件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
#docker run --name emqttd -p 18083:18083 -p 1883:1883 -p 8084:8084 -p 8883:8883 -p 8083:8083 -d registry.cn-hangzhou.aliyuncs.com/synbop/emqttd:2.3.6
#在浏览器输入机器IP:18083 就可以进入emqtt页面
#初始的账户 admin, 密码 public
#docker-compose -f emqtt-compose.yml up -d
#emqtt-compose.yml 配置文件如下  
version: "3" 
services:
 emqtt:
  image: registry.cn-hangzhou.aliyuncs.com/synbop/emqttd:2.3.6
  container_name: emqtt
  privileged: true 
  ports: 
   - 18083:18083
   - 1883:1883
   - 8084:8084
   - 8883:8883
   - 8083:8083 
  restart: always

注意:
-p 18083 服务器启动端口
-p 1882 TCP端口
-p 8083 WS端口
-p 8084 WSS端口
-p 8883 SSL端口

在外部浏览器可以访问 http://ip:18083 就可以进入emqtt页面
账号:admin,
密码:public

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；

发表于
字数统计: 921 字 | 阅读时长 ≈ 4 min

删除 所有节点中 UnexpectedAdmissionError 状态的 pod 

1
kubectl delete pods -nkube-system `kubectl get pods -nkube-system |grep UnexpectedAdmissionError |awk '{print $1}'

查看 coredns 的服务器信息

1
kubectl describe svc -n kube-system coredns

看下 0201这个节点上的pod情况

1
kubectl get pod -n kube-system -owide| grep 0201

修改 kube-system nodelocaldns 的服务信息

1
2
3
kubectl edit cm -n kube-system coredns

kubectl edit cm nodelocaldns -n kube-system

删除pod 后面可以跟多个pod 的名字删除多个

1
kubectl delete pods -nkube-system xx

用这个 只过滤50201节点的服务

1
kubectl  get pods -nkube-system -owide |grep 50201

用这个 只过滤50201节点的coredns|kube-proxy服务

1
kubectl  get pods -nkube-system -owide |grep 50201  |grep -E "coredns|kube-proxy"

修改idaas 的启动配置文件

1
kubectl edit deploy ideas

查看日志文件

1
kubectl logs pods -nkube-system

查看节点信息

1
kubectl get node 看看呢

查看那个文件大

1
2
3
4
5
ls -lh 

du -d 1 -h /var/log

du -d 1 -h /opt

cd 到根目录，查看所有的

1
du -d 1 -h .

将状态信息输出到日志文件

1
systemctl status kubelet -l > kubelet.log

启动k8s

1
systemctl start kubelet

停止k8s

1
systemctl stop kubelet

查看docker 状态

1
systemctl status docker

停止docker 

1
systemctl stop docker

看下是否起来了 

1
2
3
systemctl status kubelet -l 

journalctl   -u  kubelet -n 50

查看容器状态是否正确

1
docker ps |grep apiserver

查看主节点有多少

1
kubectl describe redisclusters.redisoperator.k8s.io bml|grep 'Number Of Master'

查看 信息

1
kubectl describe redisclusters.redisoperator.k8s.io bml

查看rediscluste信息

1
kubectl describe rediscluster-bml-xxx

链接mysql 

1
mysql -h10.233.10.1 -P8806 -ubdl -pBdl@Ape2020 ape_online

将配置文件输出到idaas-config.yaml

1
kubectl get cm idaas-config -oyaml > idaas-config.yaml

推送镜像信息

1
docker push 10.233.0.100:5000/idaas-47.0.0.115然后再重新推一下

查看仓库信息

1
docker push 10.233.0.100:5000/idaas-47.0.0.115然后再重新推一下

查看节点信息

1
2
kubectl get node -owide 
hostname -i

解压镜像信息

1
docker load -i idaas-47.0.0.115.tar

查看pod 最后200行日志

1
kubectl logs -f bdl-console-xxx --tail=200

进入容器，查看服务器信息

1
2
3
kubectl exec -it bdl-console-xxx bash

nslookup 10.233.0.3

查询鉴权是否过期

1
sudo kubectl get ds bml-authorization-server -oyaml
1
sudo curl 20.59.29.228:8443/security/license

查询是否有某个服务

1
2
3
kubectl get pods -A|grep bml-model

kubectl get deploy |grep bml-model

将模型推送到镜像

1
2
3
bmlmodel config -a xxxx -s xxxx

bmlmodel publish -l /home/bml/storage -p newmodel -n textclassify -v 1.0.0.0

描述一共pod

1
kubectl describe pods nginx

给文件增加执行权限

1
chmod +x get_machine_finger_en

执行文件

1
./get_machine_finger_en

打包当前目录下的所有文件命名为finger.tar.gz，打包完成到上级目录

1
tar cvzf ../finger.tar.gz        ./*

scp命令传文件远程ip加端口号，port为远程ip对应的端口号。

1
scp -P port filename username@ip

删除所有的报错pod
kubectl delete pod `kubectl get pod - A｜grep -v ‘Running’ |awk ‘{print $2}’

查看 registry信息
kubectl describe svc registry

看下这个服务状态
kubectl get pod -owide|grep bml-scheduler

kubectl describe svc bml-scheduler

kubectl delete pod bml-scheduler-xxx

到original/package/Install下面

python install.py rmall卸载掉

然后再python install.py inall安装

查看百度鉴权
curl http://ip:8443/security/license

看下端口有没有起来
netstat -anp|grep 8443

三个easypack节点执行这个重启下
cd /home/baidu/work/c-offline-security-server/ && bash start/c-offline-security-server-stop.sh && nohup bash start/c-offline-security-server-start.sh &

一辈子很短，努力的做好两件事就好；
第一件事是热爱生活，好好的去爱身边的人；
第二件事是努力学习，在工作中取得不一样的成绩，实现自己的价值，而不是仅仅为了赚钱；