安全的重叠构造器 - 最佳实践：Build Pattern

发表于 2018-01-28 | 分类于 java

1	effective java # 2

Builder模式，不直接生成想要的对象，而是让客户端利用所有必要的参数调用构造器，

得到一个builder对象。然后客户端在builder对象上调用类似于setter的方法，

来设置每个相关可选的参数，最后调用无参的build来生成不可变的对象。

完整代码+测试：github:完整代码+测试

public class NutritionFacts {

  private final int servingSize;
  private final int servings;
  private final int calories;
  private final int fat;
  private final int sodium;
  private final int carbohydrate;

  private NutritionFacts(Builder builder) {
    servingSize = builder.servingSize;
    servings = builder.servings;
    calories = builder.calories;
    fat = builder.fat;
    sodium = builder.sodium;
    carbohydrate = builder.carbohydrate;
  }

  public static class Builder {

    // Required parameters
    private final int servingSize;
    private final int servings;

    private int calories = 0;
    private int fat = 0;
    private int carbohydrate = 0;
    private int sodium = 0;

    public Builder(int servingSize, int servings) {
      this.servingSize = servingSize;
      this.servings = servings;
    }

    public Builder calories(int val) {
      calories = val;
      return this;
    }

    public Builder fat(int val) {
      this.fat = val;
      return this;
    }

    public Builder carbohydrate(int val) {
      this.carbohydrate = val;
      return this;
    }

    public Builder sodium(int val) {
      this.sodium = val;
      return this;
    }

    public NutritionFacts build() {
      return new NutritionFacts(this);
    }
  }



  @Override
  public String toString() {
    return "NutritionFacts{" +
        "servingSize=" + servingSize +
        ", servings=" + servings +
        ", calories=" + calories +
        ", fat=" + fat +
        ", sodium=" + sodium +
        ", carbohydrate=" + carbohydrate +
        '}';
  }
}

Java实现Singleton最佳方法 - Enum

发表于 2018-01-27 | 分类于 java

effective java：

1	单元素的枚举类型已经成为实现Singleton的最佳方法

理由：

因为枚举单例有序列化和线程安全的保证
避免反射和并发困扰

单例模式模式：完整代码+测试

主要代码：

public class EnumSingleton {

  private EnumSingleton() {
  }

  public static EnumSingleton getInstance() {
    return Singleton.INSTANCE.getInstance();
  }

  private enum Singleton {
    INSTANCE;
    private EnumSingleton singleton;

    Singleton() {
      singleton = new EnumSingleton();
    }

    public EnumSingleton getInstance() {
      return singleton;
    }
  }
}

笔记 - 读后感：《第一本Docker书》

发表于 2018-01-27 | 分类于 docker

忘记开始是在什么地方看到docker这个东西

后面觉得挺好玩，也试了很多次，找过很多的教程。

搭建了一个zookeeper的集群(docker-compose)

然后当我需要搭建redis集群的时候，发现里面很多的概念还不是很懂

比如：volume network

然后加了docker的群，遇到了在以前idea群里面熟的一个人

花了一天的时间看完他传的一本书，昨天买的几本书晚上也到了。
（docker从入门到实践、java并发编程的艺术、effective java中文版 2）

这本书总体来说还行，就是过时了，还在用link，毕竟三年前的东西

有些例子也报错，主要是ruby相关的不行，提醒需要2.2以上的版本

下面是随便做的一点笔记

阅读全文 »

Java - 利用apache POI读取Excel（xls,xlsx,2003,2007)

发表于 2018-01-13 | 分类于 java

一个简单的工具类，更多java小练习：https://github.com/hisenyuan/IDEAPractice

一、添加依赖

<!-- POI start -->
<dependency>
  <groupId>org.apache.poi</groupId>
  <artifactId>poi</artifactId>
  <version>3.9</version>
</dependency>
<dependency>
  <groupId>org.apache.poi</groupId>
  <artifactId>poi-ooxml</artifactId>
  <version>3.9</version>
</dependency>
<dependency>
  <groupId>commons-collections</groupId>
  <artifactId>commons-collections</artifactId>
  <version>3.2.2</version>
</dependency>
<!-- POI end -->

二、测试类

package com.hisen.jars.poi;

import java.io.File;
import java.io.IOException;
import java.util.Arrays;
import java.util.List;

/**
 * @author hisenyuan
 * @time 2018/1/12 17:43
 * @description 测试读取
 */
public class TestPoiExcelUtil {

  public static void main(String[] args) {
    File file = new File("C:\\work\\document\\银行信息.xlsx");
    try {
      // 每一个excelData为一行数据（存放在数组）
      List<String[]> excelData = POIExcelUtil.readExcel(file);
      for (String[] data:excelData) {
        System.out.println(Arrays.toString(data));
      }
    } catch (IOException e) {
      e.printStackTrace();
    }
  }

}

三、工具类代码

完整类：POIExcelUtil.java

package com.hisen.jars.poi;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import org.apache.log4j.Logger;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.Cell;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;

/**
 * @author hisenyuan
 * @time 2018/1/12 16:35
 * @description 利用POI读取excel表格
 */
public class POIExcelUtil {

  private static Logger logger = Logger.getLogger(POIExcelUtil.class);
  private final static String XLS = "xls";
  private final static String XLSX = "xlsx";

  public static List<String[]> readExcel(File file) throws IOException {
    // 检查文件
    checkFile(file);
    Workbook workBook = getWorkBook(file);
    // 返回对象,每行作为一个数组，放在集合返回
    ArrayList<String[]> rowList = new ArrayList<>();
    if (null != workBook) {
      for (int sheetNum = 0; sheetNum < workBook.getNumberOfSheets(); sheetNum++) {
        // 获得当前sheet工作表
        Sheet sheet = workBook.getSheetAt(sheetNum);
        if (sheet == null) {
          continue;
        }
        // 获得当前sheet的开始行
        int firstRowNum = sheet.getFirstRowNum();
        // 获得当前sheet的结束行
        int lastRowNum = sheet.getLastRowNum();
        // 循环所有行(第一行为标题)
        for (int rowNum = firstRowNum; rowNum < lastRowNum; rowNum++) {
          // 获得当前行
          Row row = sheet.getRow(rowNum);
          if (row == null) {
            continue;
          }
          // 获得当前行开始的列
          short firstCellNum = row.getFirstCellNum();
          // 获得当前行的列数
          int lastCellNum = row.getPhysicalNumberOfCells();
          String[] cells = new String[row.getPhysicalNumberOfCells()];
          // 循环当前行
          for (int cellNum = firstCellNum; cellNum < lastCellNum; cellNum++) {
            Cell cell = row.getCell(cellNum);
            cells[cellNum] = getCellValue(cell);
          }
          rowList.add(cells);
        }
      }
    }
    return rowList;
  }
}

Redis counter demo - redis并发计数器

发表于 2018-01-11 | 分类于 sql

一、说明

利用redis操作的原子性，实现java 多线程并发的情况下实现计数器。

我本机测试多个线程操作之后，结果会出现一定的延迟，但是最终数字是ok的

应该是redis内部做了一个类似于队列的功能。

需要注意的是，得使用redis连接的线程池，不然会出现异常

这里有一个：JedisUtil 下面用到了

二、代码实现

2.1 redis操作类

package com.hisen.thread.count_click_by_redis;

import com.hisen.utils.JedisUtil;
import redis.clients.jedis.JedisPool;
/**
 * @author hisenyuan
 * @description 操作redis的线程类
 */
public class ClickRedis {

  /**
   * 必须使用线程池，而且线程池要大于并发数，否则会出现redis超时
   */
  private static JedisPool jedis = JedisUtil.getPool();

  public static void click() {
    jedis.getResource().incrBy("hisen", 1);
  }

  public static int getCount() {
    return Integer.parseInt(jedis.getResource().get("hisen"));
  }

  public static void declare() {
    jedis.getResource().del("hisen");
    jedis.close();
  }
}

2.2 线程类,模拟点击

package com.hisen.thread.count_click_by_redis;

/**
 * @author hisenyuan
 * @description 执行点击的线程类
 */
public class CountClickByRedisThread extends Thread{

  private int id;
  public CountClickByRedisThread(int id) {
    this.id = id;
  }

  @Override
  public void run() {
    super.run();
    ClickRedis.click();
    int count = ClickRedis.getCount();
    System.out.println("task:" + id + "\t 执行完毕\t线程编号：" + this.getId() + "\t当前值：" + count);
  }
}

2.3 主线程 - 启动类

package com.hisen.thread.count_click_by_redis;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class Main {

  public static void main(String[] args) throws InterruptedException {
    /**
     * 5 - corePoolSize：核心池的大小
     * 10 - maximumPoolSize：线程池最大线程数，它表示在线程池中最多能创建多少个线程
     * 200 - keepAliveTime：表示线程没有任务执行时最多保持多久时间会终止。
     * unit - unit：参数keepAliveTime的时间单位，有7种取值
     * workQueue：一个阻塞队列，用来存储等待执行的任务
     */
    ThreadPoolExecutor executor = new ThreadPoolExecutor(
        50,
        100,
        200,
        TimeUnit.MICROSECONDS,
        new ArrayBlockingQueue<Runnable>(50));
    // 开启50个线程
    for (int i = 0; i < 50; i++) {
      executor.execute(new CountClickByRedisThread(i));
    }
    System.out.println("已经开启所有的子线程");
    // 启动一次顺序关闭，执行以前提交的任务，但不接受新任务。
    executor.shutdown();
    // 判断所有线程是否已经执行完毕
    while (true) {
      if (executor.isTerminated()) {
        System.out.println("所有的子线程都结束了！");
        // 清除redis数据
        ClickRedis.declare();
        break;
      }
      Thread.sleep(100);
    }
  }

}

rabbitMQ的安装和Demo

发表于 2018-01-11 | 分类于 java

零、rabbitMQ介绍

rabbitMQ详细介绍

如果某个queue有多个订阅，消息分均分到消费者，而不是所有人都收到全部
接收消息有ack(acknowledgment)机制，发送消息是没有这个机制的

生产者将消息发送到Exchange（交换器），由Exchange将消息路由到一个或多个Queue中（或者丢弃）。

一、在ununtu上安装

1.1 安装

echo 'deb http://www.rabbitmq.com/debian/ testing main' | sudo tee /etc/apt/sources.list.d/rabbitmq.list

wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -

sudo apt-get update

sudo apt-get install rabbitmq-server

1.2 配置

# 打开管理页面功能
sudo rabbitmq-plugins enable rabbitmq_management
# 查看安装的插件
sudo rabbitmqctl list_users
# 查看用户
sudo rabbitmqctl list_users
# 新增管理员用户
sudo rabbitmqctl add_user admin admin
# 授予管理员权限
sudo rabbitmqctl set_user_tags admin administrator
# 管理页面地址，用刚设置的账户登录管理页面

http://127.0.0.1:15672

二、Java小Demo

2.1 遇到的问题

ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN.
帐号密码错误，建议使用2.3配置的账户，guest账户不靠谱
connection error
ip或者port错误，确认信息是否正确，虚拟机的话看看端口映射是否正常

2.2 配置用户

# 添加普通用户
sudo rabbitmqctl add_user hisen hisen
# 添加权限
rabbitmqctl set_permissions -p "/"  hisen ".*" ".*" ".*"
# 列出用户权限
rabbitmqctl list_user_permissions hisen

2.3 添加maven依赖

<dependency>
  <groupId>com.rabbitmq</groupId>
  <artifactId>amqp-client</artifactId>
  <version>5.0.0</version>
</dependency>

2.4 发送端代码

阅读全文 »

DockerFile - 创建java开发环境镜像

发表于 2018-01-11 | 分类于 linux

使用ubuntu官方发布的docker镜像进行二次修改

这是一个菜鸟的脚本，执行命令应该是使用 & 连接，一个RUN命令搞定

FROM    ubuntu
MAINTAINER      Fisher "[email protected]"
RUN     /bin/echo 'root:hisen' |chpasswd
RUN     useradd hisen
RUN     /bin/echo 'hisen:hisen' |chpasswd
RUN     /bin/echo -e "LANG=\"en_US.UTF-8\"" >/etc/default/local
# 显示系统位数
RUN		uname -p
# 清空源 
RUN     echo "" > /etc/apt/sources.list
# 更换为阿里云源
RUN		echo "deb http://mirrors.aliyun.com/ubuntu/ xenial main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb http://mirrors.aliyun.com/ubuntu/ xenial-proposed main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb-src http://mirrors.aliyun.com/ubuntu/ xenial main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb-src http://mirrors.aliyun.com/ubuntu/ xenial-security main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb-src http://mirrors.aliyun.com/ubuntu/ xenial-updates main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb-src http://mirrors.aliyun.com/ubuntu/ xenial-proposed main restricted universe multiverse" >> /etc/apt/sources.list
RUN		echo "deb-src http://mirrors.aliyun.com/ubuntu/ xenial-backports main restricted universe multiverse" >> /etc/apt/sources.list
# 更新源
RUN		apt-get update
# 安装软件
RUN     apt-get -y install vim
RUN     apt-get -y install curl
RUN     apt-get -y install wget
RUN     apt-get -y install net-tools
RUN     apt-get -y install iputils-ping
RUN     apt-get -y install git
# 创建软件文件夹
RUN     mkdir -p /usr/hisen/soft/java
RUN     mkdir -p /usr/hisen/soft/tomcat
RUN     mkdir -p /usr/hisen/soft/maven
RUN     mkdir -p /usr/hisen/soft/download
# 添加本地软件包到指定文件夹（会自动解压，软件压缩包必须放在docker同级目录）
ADD jdk-8u151-linux-x64.tar.gz /usr/hisen/soft/java/
ADD apache-tomcat-8.5.24.tar.gz /usr/hisen/soft/tomcat/
ADD apache-maven-3.5.2-bin.tar.gz /usr/hisen/soft/maven/

# 配置环境变量
# java
ENV JAVA_HOME=/usr/hisen/soft/java/jdk1.8.0_151
ENV JRE_HOME=$JAVA_HOME/jre
ENV CLASSPATH=.:$CLASSPATH:$JAVA_HOME/lib:$JRE_HOME/lib
ENV PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
# tomcat
ENV CATALINA_HOME=/usr/hisen/soft/tomcat/apache-tomcat-8.5.24
ENV CLASSPATH=.:$JAVA_HOME/lib:$CATALINA_HOME/lib
ENV PATH=$PATH:$CATALINA_HOME/bin
# maven
ENV MAVEN_HOME=/usr/hisen/soft/maven/apache-maven-3.5.2
ENV MAVEN_OPTS="-Xms256m -Xmx512m"
ENV PATH=${MAVEN_HOME}/bin:$PATH

# 监听端口
EXPOSE  22
EXPOSE  80
EXPOSE  8080
CMD     /usr/sbin/sshd -D

MySql的执行计划

发表于 2017-11-23 | 分类于 sql

###命令介绍
MySQL的EXPLAIN命令用于SQL语句的查询执行计划(QEP)。

这条命令的输出结果能够让我们了解MySQL 优化器是如何执行

执行下面的SQL

1	explain select * FROM book where name like '活%'

得到下面的数据

id	select_type	table	partitions	type	possible_keys	key	key_len	ref	rows	filered	Extra
编号	查询方式	表名	分区	连接方式	索引(可能)	索引	索引长度	作用列	行数	百分比	额外
1	SIMPLE	book	null	ALL	null	null	null	null	114	11.11	Using where

###建表语句

阅读全文 »

Spring - IOC和AOP的原理

发表于 2017-11-20 | 分类于 java

简单理解IOC和AOP

IOC：Inversion of Control，依赖倒置

生活场景助记

如有有天你想喝一瓶矿泉水，你可以去小区便利店，告诉老板你要买矿泉水，然后老板卖给你。

但是你可能需要想这下雨天怎么去小卖部？是否要带伞？去了之后是否有我想要的水等一系列问题。

解决这个问题：

使用外卖！到平台注册，告诉平台你需要什么水。
平台给你送到家，你只管付钱拿到水之后直接喝，不用考虑上述问题。

是不是和Spring的做法很类似呢？Spring就是小卖部，你就是A对象，水就是B对象
第一：在Spring中声明一个类：A
第二：告诉Spring，A需要B

阅读全文 »

dubbo与zookeeper的关系

发表于 2017-11-15 | 分类于 java

Zookeeper的作用

zookeeper用来注册服务和进行负载均衡，哪一个服务由哪一个机器来提供必需让调用者知道，简单来说就是ip地址和服务名称的对应关系。

当然也可以通过硬编码的方式把这种对应关系在调用方业务代码中实现，但是如果提供服务的机器挂掉调用者无法知晓，如果不更改代码会继续请求挂掉的机器提供服务。

zookeeper通过心跳机制可以检测挂掉的机器并将挂掉机器的ip和服务对应关系从列表中删除。至于支持高并发，简单来说就是横向扩展，在不更改代码的情况通过添加机器来提高运算能力。

通过添加新的机器向zookeeper注册服务，服务的提供者多了能服务的客户就多了。

dubbo

是管理中间层的工具，在业务层到数据仓库间有非常多服务的接入和服务提供者需要调度，dubbo提供一个框架解决这个问题。

注意这里的dubbo只是一个框架，至于你架子上放什么是完全取决于你的，就像一个汽车骨架，你需要配你的轮子引擎。

这个框架中要完成调度必须要有一个分布式的注册中心，储存所有服务的元数据，你可以用zk，也可以用别的，只是大家都用zk。

zookeeper和dubbo的关系

Dubbo的将注册中心进行抽象，是得它可以外接不同的存储媒介给注册中心提供服务，有ZooKeeper，Memcached，Redis等。

引入了ZooKeeper作为存储媒介，也就把ZooKeeper的特性引进来。

负载均衡:单注册中心的承载能力是有限的，在流量达到一定程度的时候就需要分流，负载均衡就是为了分流而存在的，一个ZooKeeper群配合相应的Web应用就可以很容易达到负载均衡；
资源同步:单单有负载均衡还不够，节点之间的数据和资源需要同步，ZooKeeper集群就天然具备有这样的功能；
1. 命名服务:将树状结构用于维护全局的服务地址列表，服务提供者在启动的时候，向ZK上的指定节点/dubbo/${serviceName}/providers目录下写入自己的URL地址，这个操作就完成了服务的发布
2. Mast选举，分布式锁等。

参考

https://www.cnblogs.com/xiaofei1208/p/7077733.html

一、添加依赖

二、测试类

三、工具类代码

一、说明

二、 代码实现

2.1 redis操作类

2.2 线程类,模拟点击

零、rabbitMQ介绍

一、在ununtu上安装

1.1 安装

1.2 配置

二、Java小Demo

2.1 遇到的问题

2.2 配置用户

2.3 添加maven依赖

2.4 发送端代码

简单理解IOC和AOP

IOC：Inversion of Control，依赖倒置

生活场景助记

Zookeeper的作用

dubbo

zookeeper和dubbo的关系

参考

二、代码实现