Happywzy

# docker安装
docker run -d --name tdengine tdengine/tdengine
# 进入容器
docker exec -it tdengine /bin/bash
# 容器内执行命令
taosdemo
# 上述命令运行结束,进入tdengine终端
taos

taosdemo命令将在数据库 test 下面自动创建一张超级表 meters，该超级表下有 1 万张表，表名为 “d0” 到 “d9999”，每张表有 1 万条记录，每条记录有 (ts, current, voltage, phase) 四个字段，时间戳从 “2017-07-14 10:40:00 000” 到 “2017-07-14 10:40:09 999”，每张表带有标签 location 和 groupId，groupId 被设置为 1 到 10， location 被设置为 “beijing” 或者 “shanghai”。

taosdemo命令本身带有很多选项，配置表的数目、记录条数等等，请执行 taosdemo –help详细列出

-- 查看数据库。
show databases;
-- 查看超级表
use test;
show stables;
-- 查看表，限制输出十条
select * from test.t0 limit 10;
-- 查看 d0 表的标签值
select groupid, location from test.d0;
-- 查询超级表下记录总条数
select count(*) from test.meters;
-- 查询1亿条记录的平均值、最大值、最小值等
select avg(current), max(voltage), min(phase) from test.meters;
-- 查询location="beijing"的记录总条数
select count(*) from test.meters where location="beijing";
-- 查询groupId=10的所有记录的平均值、最大值、最小值等
select avg(current), max(voltage), min(phase) from test.meters where groupId=10;
-- 对表d10按10s进行平均值、最大值和最小值聚合统计
select avg(current), max(voltage), min(phase) from test.d10 interval(10s);

引入依赖

<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger2</artifactId>
    <version>2.9.2</version>
</dependency>
<dependency>
    <groupId>io.springfox</groupId>
    <artifactId>springfox-swagger-ui</artifactId>
    <version>2.9.2</version>
</dependency>

配置

@Configuration
@EnableSwagger2
public class SwaggerConfig {
    @Bean
    public Docket createRestApi(){
        return new Docket(DocumentationType.SWAGGER_2).apiInfo(apiInfo())
                .select()
                .apis(RequestHandlerSelectors.any())
                .paths(PathSelectors.any()).build();
    }

    private ApiInfo apiInfo(){
        return new ApiInfoBuilder()
                .title("Demo API Doc")
                .description("This is a restful api document of Demo.")
                .version("1.0")
                .build();
    }
}

访问UI

• http://localhost:17070/swagger-ui.html

常用注解：

• @Api()用于类；
  表示标识这个类是swagger的资源
• @ApiOperation()用于方法；
  表示一个http请求的操作
  - @ApiParam()用于方法，参数，字段说明；
  表示对参数的添加元数据（说明或是否必填等）
  - @ApiModel()用于类
  表示对类进行说明，用于参数用实体类接收
• @ApiModelProperty()用于方法，字段
  表示对model属性的说明或者数据操作更改
• @ApiIgnore()用于类，方法，方法参数
  表示这个方法或者类被忽略
• @ApiImplicitParam() 用于方法
  表示单独的请求参数
• @ApiImplicitParams()用于方法，包含多个 @ApiImplicitParam

示例

@RestController
@RequestMapping("/xxtest")
@Api(tags = "这里修改大类的名字", description = "这里修改大类的描述")
public class SysRoleController {

    @ApiImplicitParams({
        @ApiImplicitParam(name = "Authorization", value = "请求Header的名称", required = true, dataType = "String",paramType = "header"),
    })
    @ApiOperation(value = "修改接口的描述")
    @PostMapping("/test")
    public Response add(@RequestParam(value = "name") @ApiParam(value = "这里写参数名字") String name) {
        return roleService.add(name);
    }

    @ApiImplicitParams({
        @ApiImplicitParam(name = "Authorization", value = "认证Token", required = true, dataType = "String",paramType = "header"),
        @ApiImplicitParam(name = "name", value = "也可以在这里写参数的名称", dataType = "integer",paramType = "query"),
    })
    @ApiOperation(value = "修改接口的描述")
    @PostMapping("/test")
    public Response add(@RequestParam(value = "name") String name) {
        return roleService.add(name);
    }
}

@ApiModel(description = "测试实体")
public class TestEntity {
    @ApiModelProperty(value = "名称")
    private String name;
    @ApiModelProperty(value = "ID")
    private Integer id;
}

// influxdb客户端超时是由于http超时导致.
// 1. 声明 OkHttpClient 设置超时时间
static OkHttpClient.Builder build = new OkHttpClient.Builder()
            .readTimeout(20, TimeUnit.SECONDS);

// 2. 
InfluxDB influxDB = InfluxDBFactory.connect("http://127.0.0.1:8086", build);

• 创建一个能运行docker命令的基础镜像

FROM hub.deri.org.cn/library/openjdk:8-jdk-alpine
MAINTAINER wuzhiyong Docker Maintainers "wuzhiyong@deri.energy"
RUN echo "Asia/shanghai" > /etc/timezone
RUN apk add docker
ENV LANG C.UTF-8

• 创建java镜像

FROM hub.deri.org.cn/library/openjdk:8-jdk-alpine-docker
MAINTAINER wuzhiyong Docker Maintainers "wuzhiyong@deri.energy"
ADD route-1.0.0-SNAPSHOT.jar /root
EXPOSE 8080
ENV LANG C.UTF-8
CMD cd /root  && java -jar route-1.0.0-SNAPSHOT.jar

• 启动容器必须携带的

 -v /var/run/docker.sock:/var/run/docker.sock

这样启动起来的java容器内，可以直接执行docker命令,如docker ps获取宿主机所有运行的容器列表.

redis连接配置：

 @Bean
RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory) {
    RedisMessageListenerContainer container = new RedisMessageListenerContainer();
    container.setConnectionFactory(connectionFactory);
    return container;
}

消息监听器：

@Component
public class RedisCallBack extends KeyExpirationEventMessageListener {

    public RedisCallBack(RedisMessageListenerContainer listenerContainer) {
        super(listenerContainer);
    }

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("过期key:" + message.toString());
    }
}

<div>
    <label class="radio-inline">
        <input type="radio" name="expire" th:value="1" th:checked="true"/>6小时
    </label>
    <label class="radio-inline">
        <input type="radio" name="expire" th:value="2"/>12小时
    </label>
    <label class="radio-inline">
        <input type="radio" name="expire" th:value="3"/>1天
    </label>
    <label class="radio-inline">
        <input type="radio" name="expire" th:value="4"/>3天
    </label>
    <label class="radio-inline">
        <input type="radio" name="expire" th:value="5"/>7天
    </label>
</div>

表单提交时如何获取用户选中了哪个单选框呢？

var expire = $("input[name='expire']:checked").val();