0%

规范使用枚举类

public enum StatEnum {
    SUCCESS(1,"成功"),
    END(0,"失败"),
    REPEAT_KILL(-1,"重复"),
    INNER_ERROR(-2,"系统异常"),
    DATA_REWRITE(-3,"数据异常");

    private  int state;

    private  String stateInfo;

    StatEnum(int state, String stateInfo) {
        this.state = state;
        this.stateInfo = stateInfo;
    }

    public int getState() {
        return state;
    }

    public String getStateInfo() {
        return stateInfo;
    }

    public static StatEnum stateOf(int index){
        for(StatEnum state: values()){
            if(state.getState() == index){
                return state;
            }
        }
        return  null;
    }
}

枚举搭配接口一起使用

// 定义接口
public interface CodeEnum {
    Integer getCode();
    
    String getMessage();
}
// 定义枚举
public enum StatusEnum implements CodeEnum {
    UP(0, "成功"),
    DOWN(1, "失败");
    private Integer code;

    private String message;

    StatusEnum(Integer code, String message) {
        this.code = code;
        this.message = message;
    }
    
    @Override
    public Integer getCode() {
        return code;
    }

    @Override
    public String getMessage() {
        return message;
    }
}
// 定义工具类
public class EnumUtil {

    public static <T extends CodeEnum> T getByCode(Integer code, Class<T> enumClass) {
        for (T each: enumClass.getEnumConstants()) {
            if (code.equals(each.getCode())) {
                return each;
            }
        }
        return null;
    }
}

使用:

  • EnumUtil.getByCode(0, StatusEnum.class).getMessage()
  • EnumUtil.getByCode(1, StatusEnum.class).getCode()

浏览器地址显示问题

  • return "forward:/list"; 浏览器地址不变,是转发源地址;

  • return "redirect:/list"; 浏览器地址变成list地址.

使用exchange

import com.alibaba.fastjson.JSON;
import com.crd.service.routing.bean.AddrInfo;
import com.crd.service.routing.bean.Response;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.http.*;
import org.springframework.util.MimeType;
import org.springframework.util.MimeTypeUtils;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import java.nio.charset.Charset;

/**
 * @Author: wzy
 * @Time: Created on 2018/4/27 16:04
 * @Project: sg-imq-console
 * @Modified By: 使用exchange发送put,delete,解决resttemplate无返回值问题
 */
public class RestClientUtil {
    /**
     * 发送/获取 服务端数据(主要用于解决发送put,delete方法无返回值问题).
     *
     * @param url    绝对地址
     * @param method 请求方式
     * @param <T>    返回类型
     * @return 返回结果(响应体)
     */
    public static <T> T exchange(String url, HttpMethod method, Class<T> response, String request) {
        // 请求头
        HttpHeaders headers = new HttpHeaders();
        MimeType mimeType = MimeTypeUtils.parseMimeType("application/json");
        MediaType mediaType = new MediaType(mimeType.getType(), mimeType.getSubtype(), Charset.forName("UTF-8"));
        headers.setContentType(mediaType);
        // 发送请求
        HttpEntity<String> entity = new HttpEntity<>(request, headers);
        RestTemplate restTemplate = new RestTemplate();
        ResponseEntity<T> resultEntity = restTemplate.exchange(url, method, entity, response);
        return resultEntity.getBody();
    }

    public static void main(String[] args) {
        String url = "http://127.0.0.1:8088/route/addr/安徽";
        AddrInfo addrInfo = new AddrInfo("安徽", "127.0.0.1:9877");
//        Response response = RestClientUtil.exchange(url,HttpMethod.PUT,Response.class,
//                JSON.toJSONString(addrInfo));
        Response response = RestClientUtil.exchange(url, HttpMethod.DELETE, Response.class,
                null);
        System.out.println(response);
//        RestTemplate restTemplate = new RestTemplate();
//        restTemplate.put(url, addrInfo);
    }
}

Hbase关于TTL

  • ColumnFamilies可以以秒为单位来设置 TTLTime To Live)长度,一旦达到到期时间,HBase 将自动删除行。
  • 设置 hbase.store.delete.expired.storefilefalse 将禁用此功能。将最小版本数设置为 0 以外的值也会禁用此功能。
  • 也支持设置时间以每个单元为基础生存。单元TTL 是使用突变 setTTL 作为突变请求(例如:AppendsIncrementsPuts)的属性提交的.
  • 单元 TTL 以毫秒为单位而不是秒;
  • 单元 TTL 不能将一个单元的有效生命周期延长超过 ColumnFamilyTTL 设置.

设置TTL

  1. 创建表的时候指定
create 't_task_log',{NAME => 'cf', TTL=>'86400'}
  1. 查看TTL
desc "t_task_log"
-- 默认: TTL => 'FOREVER'
  1. 修改TTL
-- 禁用表
disable "t_task_log"
-- 设置TTL值,作用于列族cf
alter "t_task_log",NAME=>'cf',TTL=>'86400'
-- 恢复表
enable  "t_task_log"

高版本hbase可以不需要先禁用表,可直接在线修改TTL.

  1. 编码设置列族TTL
// 1. 创建一个测试表,并添加列族cf
TableName tableName = TableName.valueOf("test");
TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)
        .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder("cf".getBytes()).build())
        .build();

admin.createTable(tableDescriptor);
System.out.println("创建表并添加列族cf成功");

// 2.为当前的表添加一个ttl的列族(默认设定时间为10秒)
ColumnFamilyDescriptor cfDesc = ColumnFamilyDescriptorBuilder.newBuilder("ttl-cf".getBytes()).setTimeToLive(10)
        .build();
admin.addColumnFamily(tableName, cfDesc);
System.out.println("为表添加一个具有TTL的列族ttl-cf,设定超时时间为10s");
  1. 编码设置单元TTL
Put put = new Put(Bytes.toBytes("row1"));
put.setTTL(86400L);

怎么重置TTL为FOREVER

-- HBase TTL 最大值为INT最大值 2147483647,只需将TTL设为该整数即可
alter 'test',{NAME => 'cf',TTL => '2147483647'}

参考链接

问题

docker-compose配置容器启动顺序,有时依靠depends_on并不能完全解决,主要原因是:

解决方案

启动命令前增加判断依赖服务状态的工具

示例:

version: "2"
services:
  web:
    build: .
    ports:
      - "80:8000"
    depends_on:
      - "db"
    command: ["./wait-for-it.sh", "db:5432", "--", "python", "app.py"]
  db:
    image: postgres

自己编写script

#!/bin/sh
# wait-for-postgres.sh

set -e
  
host="$1"
shift
cmd="$@"
  
until PGPASSWORD=$POSTGRES_PASSWORD psql -h "$host" -U "postgres" -c '\q'; do
  >&2 echo "Postgres is unavailable - sleeping"
  sleep 1
done
  
>&2 echo "Postgres is up - executing command"
exec $cmd

测试:

command: ["./wait-for-postgres.sh", "db", "python", "app.py"]

wait-for命令测试

[root@node1 ~]# chmod a+x wait_for 
[root@node1 ~]# ./wait_for localhost:3306 -- echo "Mysql site is up"
Eficode site is up

配置selinux标签

如果使用selinux,则可以添加zZ选项来修改要装入容器的主机文件或目录的selinux标签。这会影响主机本身上的文件或目录,并可能导致超出Docker范围的后果。

  • 该z选项指示绑定安装内容在多个容器之间共享。
  • 该Z选项指示绑定安装内容是私有的且未共享。

这些选项请格外小心。绑定安装系统目录(例如/home/usr带有该Z选项)会使主机无法操作,并且您可能需要手动重新标记主机文件。

重要说明:将绑定安装与服务一起使用时,selinux标签(:Z:z)以及将:ro被忽略。

本示例设置z选项以指定多个容器可以共享绑定安装的内容:

无法使用该--mount标志修改selinux标签。

docker run -d \
  -it \
  --name devtest \
  -v "$(pwd)"/target:/app:z \
  nginx:latest

原文地址