公共子模块common模块entry、utils包代码以及分布式

作者: 神豪VS勇士赢 | 来源:发表于2019-02-23 10:58 被阅读0次

公共子模块common模块entry、utils包代码以及分布式
什么是模块化，组件化，插件化？
ThinkPHP目录结构
【IDEA】搭建聚合项目抛Unable to find main
【IDEA】解决maven多工程项目"找不到符号"问题
架构师（四）——组件化子模块交互
H5项目目录结构及说明
Sentinel之集群限流源码分析（一）
iOS - 编码规范
Zheng——项目结构

一、上文我们已经完成了创建common子模块
接下来我们在里面创建返回实体类
新建 entry包

image.png
在包下面创建 Result类用于控制器返回结果：
public class Result {
/**
* 是否成功
/
private boolean flag;
/*
* 返回码
/
private Integer code;
/*
* 返回信息
/
private String message;
/*
* 返回数据
*/
private Object data;

public Result() {
}

public Result(boolean flag, Integer code, String message) {
    this.flag = flag;
    this.code = code;
    this.message = message;
}

public Result(boolean flag, Integer code, String message, Object data) {
    this.flag = flag;
    this.code = code;
    this.message = message;
    this.data = data;
}

public boolean isFlag() {
    return flag;
}

public void setFlag(boolean flag) {
    this.flag = flag;
}

public Integer getCode() {
    return code;
}

public void setCode(Integer code) {
    this.code = code;
}

public String getMessage() {
    return message;
}

public void setMessage(String message) {
    this.message = message;
}

public Object getData() {
    return data;
}

public void setData(Object data) {
    this.data = data;
}

这里面我们使用很原始的set get 也可以使用lombook 通过注释来完成实体的一些操作。

接下来创建分页结果类：

public class PageResult <T>{
private Long total;
private List<T> rows;

public PageResult() {
}

public PageResult(Long total, List<T> rows) {
    this.total = total;
    this.rows = rows;
}

public Long getTotal() {
    return total;
}

public void setTotal(Long total) {
    this.total = total;
}

public List<T> getRows() {
    return rows;
}

public void setRows(List<T> rows) {
    this.rows = rows;
}

}
接下来创建状态码实体类：
public class StatusCode {
/**
* 成功
/
public static final int OK=20000;
/*
* 失败
/
public static final int ERROR =20001;
/*
* 用户名或密码错误
/
public static final int LOGINERROR =20002;
/*
* 权限不足
/
public static final int ACCESSERROR =20003;
/*
* 远程调用失败
/
public static final int REMOTEERROR =20004;
/*
* 重复操作
/
public static final int REPERROR =20005;
/*
* 验证码过期
*/
public static final int VERIFICATION =20006;
}

接下来我们需要解除一个新的分布式的ID生成器：

image.png

在 comnon包下创建 util包

image.png

IdWorker 代码如下: 我们直接引用这个代码直接来使用：
package util;

import java.lang.management.ManagementFactory;
import java.net.InetAddress;
import java.net.NetworkInterface;

/**

名称：IdWorker.java
描述：分布式自增长ID
<pre>

Twitter的 Snowflake　JAVA实现方案

</pre>
核心代码为其IdWorker这个类实现，其原理结构如下，我分别用一个0表示一位，用—分割开部分的作用：
1||0---0000000000 0000000000 0000000000 0000000000 0 --- 00000 ---00000 ---000000000000
在上面的字符串中，第一位为未使用（实际上也可作为long的符号位），接下来的41位为毫秒级时间，
然后5位datacenter标识位，5位机器ID（并不算标识符，实际是为线程标识），
然后12位该毫秒内的当前毫秒内的计数，加起来刚好64位，为一个Long型。
这样的好处是，整体上按照时间自增排序，并且整个分布式系统内不会产生ID碰撞（由datacenter和机器ID作区分），
并且效率较高，经测试，snowflake每秒能够产生26万ID左右，完全满足需要。
64位ID (42(毫秒)+5(机器ID)+5(业务编码)+12(重复累加))
@author Polim
/
public class IdWorker {
/*
- 时间起始标记点，作为基准，一般取系统的最近时间（一旦确定不能变动）
 /
 private final static long twepoch = 1288834974657L;
 /*
- 机器标识位数
 /
 private final static long workerIdBits = 5L;
 /*
- 数据中心标识位数
 /
 private final static long datacenterIdBits = 5L;
 /*
- 机器ID最大值
 /
 private final static long maxWorkerId = -1L ^ (-1L << workerIdBits);
 /*
- 数据中心ID最大值
 /
 private final static long maxDatacenterId = -1L ^ (-1L << datacenterIdBits);
 /*
- 毫秒内自增位
 /
 private final static long sequenceBits = 12L;
 /*
- 机器ID偏左移12位
 /
 private final static long workerIdShift = sequenceBits;
 /*
- 数据中心ID左移17位
 /
 private final static long datacenterIdShift = sequenceBits + workerIdBits;
 /*
- 时间毫秒左移22位
 */
 private final static long timestampLeftShift = sequenceBits + workerIdBits + datacenterIdBits;
private final static long sequenceMask = -1L ^ (-1L << sequenceBits);
/**
- 上次生产id时间戳
 /
 private static long lastTimestamp = -1L;
 /*
- 0，并发控制
 /
 private long sequence = 0L;
 /*
- 工作机器ID
 /
 private final long workerId;
 /*
- 数据标识id部分
 */
 private final long datacenterId;
public IdWorker() {
this.datacenterId = getDatacenterId(maxDatacenterId);
this.workerId = getMaxWorkerId(datacenterId, maxWorkerId);
}

/**
- @param workerId 工作机器ID
- @param datacenterId 序列号
 */
 public IdWorker(long workerId, long datacenterId) {
 if (workerId > maxWorkerId || workerId < 0) {
 throw new IllegalArgumentException(String.format("worker Id can't be greater than %d or less than 0", maxWorkerId));
 }
 if (datacenterId > maxDatacenterId || datacenterId < 0) {
 throw new IllegalArgumentException(String.format("datacenter Id can't be greater than %d or less than 0", maxDatacenterId));
 }
 this.workerId = workerId;
 this.datacenterId = datacenterId;
 }
/**
- 获取下一个ID
- @return
 */
 public synchronized long nextId() {
 long timestamp = timeGen();
 if (timestamp < lastTimestamp) {
 throw new RuntimeException(String.format("Clock moved backwards. Refusing to generate id for %d milliseconds", lastTimestamp - timestamp));
 }
 
 if (lastTimestamp == timestamp) {
 // 当前毫秒内，则+1
 sequence = (sequence + 1) & sequenceMask;
 if (sequence == 0) {
 // 当前毫秒内计数满了，则等待下一秒
 timestamp = tilNextMillis(lastTimestamp);
 }
 } else {
 sequence = 0L;
 }
 lastTimestamp = timestamp;
 // ID偏移组合生成最终的ID，并返回ID
 long nextId = ((timestamp - twepoch) << timestampLeftShift)
 | (datacenterId << datacenterIdShift)
 | (workerId << workerIdShift) | sequence;
 
 return nextId;
 }
private long tilNextMillis(final long lastTimestamp) {
long timestamp = this.timeGen();
while (timestamp <= lastTimestamp) {
timestamp = this.timeGen();
}
return timestamp;
}

private long timeGen() {
return System.currentTimeMillis();
}

/**
- 
- 获取 maxWorkerId
- 
 /
 protected static long getMaxWorkerId(long datacenterId, long maxWorkerId) {
 StringBuffer mpid = new StringBuffer();
 mpid.append(datacenterId);
 String name = ManagementFactory.getRuntimeMXBean().getName();
 if (!name.isEmpty()) {
 /
 * GET jvmPid
 /
 mpid.append(name.split("@")[0]);
 }
 /
 - MAC + PID 的 hashcode 获取16个低位
 */
 return (mpid.toString().hashCode() & 0xffff) % (maxWorkerId + 1);
 }
/**
- 
- 数据标识id部分
- 
 */
 protected static long getDatacenterId(long maxDatacenterId) {
 long id = 0L;
 try {
 InetAddress ip = InetAddress.getLocalHost();
 NetworkInterface network = NetworkInterface.getByInetAddress(ip);
 if (network == null) {
 id = 1L;
 } else {
 byte[] mac = network.getHardwareAddress();
 id = ((0x000000FF & (long) mac[mac.length - 1])
 | (0x0000FF00 & (((long) mac[mac.length - 2]) << 8))) >> 6;
 id = id % (maxDatacenterId + 1);
 }
 } catch (Exception e) {
 System.out.println(" getDatacenterId: " + e.getMessage());
 }
 return id;
 }

}

公共子模块common模块entry、utils包代码以及分布式
一、上文我们已经完成了创建common子模块接下来我们在里面创建返回实体类新建 entry包这里面我们使用很原始...
什么是模块化，组件化，插件化？
模块化Android Studio的common模块， common_business模块。相比于包来讲，模块更灵...
ThinkPHP目录结构
Application├─Common 应用公共模块│ ├─Common 应用公共函数目录│ └─Conf 应用公...
【IDEA】搭建聚合项目抛Unable to find main
背景项目是springboot，分多模块：common公共模块、order订单模块和stock库存模块。项目在i...
【IDEA】解决maven多工程项目"找不到符号"问题
背景项目是springboot，分多模块：common公共模块(不需要build)、order订单模块(需要bu...
架构师（四）——组件化子模块交互
假设有两个子模块order和persional，以及公共库common 由于是子模块，他们没有互相依赖（就是在bu...
H5项目目录结构及说明
common/ -->公共模块文件夹 controllers/ -->公用控制器 templates/ ...
Sentinel之集群限流源码分析（一）
集群限流源码分析（一） sentinel-cluster-common-default: 公共模块，包含公共接口和...
iOS - 编码规范
1.⼯程⽬录说明 1.1. Common放公共代码，Pages放业务模块相关 1.2. Manager全局管理类，...
Zheng——项目结构
zheng├── zheng-common -- SSM框架公共模块├── zheng-admin -- 后台管理...