fomjar-core

• 提供了Aliyun中间件和开源中间件的统一封装，在各类场景下给出可用方案。
• 在模块复杂或工程化的集成场景下提供有用的工具库。

目录

• dist: 分布式包。各类分布式中间件的统一封装。在Spring环境下会进行Bean的自动配置。分布式锁、选举等
• el: 表达式包。各类模板引擎和表达式引擎的统一封装。也可以用来做Web端推送。在Spring环境下会进行Bean的自动配置。支持注册自定义变量、自定义方法
• lang: 基础功能宝。包括：算法摘要、注解扫描、异步任务、数据结构等
• lio: 长连接包。各类网络协议的长连接的统一封装。在Spring环境下提供了基于注解的LIO容器自动配置。Websocket、Socket-IO、TCP、Redis
• mq: 消息队列包。各类消息中间件的统一封装。在Spring环境下会进行Bean的自动配置。AliyunMQ、RedisMQ
• oss: 对象存储包。各类对象存储中间件的统一封装。在Spring环境下会进行Bean的自动配置。AliyunOSS、MinioOSS
• pio: 进程IO包。操作系统进程的IO异步读写工具
• spring: Spring支持包。框架的Spring启动器自动配置以及Spring相关工具集。动态获取Bean、动态获取配置项等

依赖导入

<dependency>
    <groupId>com.fomjar</groupId>
    <artifactId>fomjar-core</artifactId>
    <version>1.0.5</version>
</dependency>

DEMO

lang(基础功能)

支持的摘要算法：md2、md5、sha1、sha256、sha384、sha512、crc32。

System.out.println(Digest.md5("password"));

简单的注解扫描

Anno.scan("com.fomjar.core", new AnnoScanAdapter() {
    @Override
    public void read(Annotation[] annotations, Class<?> clazz) {
        if (0 < annotations.length)
            System.out.println(clazz);
        for (Annotation annotation : annotations) {
            System.out.println("[CLASS  ANNO] " + annotation.annotationType());
        }
    }
}

这是一个扫描Controller接口清单的例子：

Anno.scan(new URLClassLoader(new URL[]{
                new File("/Users/fomjar/Documents/code/fomjar-core/target/classes").toURI().toURL(),
        }),
        "com.fomjar.core",
        null,
        AnnoScanFilter.any(Controller.class, RestController.class),
        new AnnoScanAdapter() {
            @Override
            public void read(Annotation[] annotations, Class<?> type, Method method) {
                Annotation anno0 = Anno.any(type.getAnnotations(), RequestMapping.class, GetMapping.class, PostMapping.class);
                Annotation anno1 = Anno.any(method.getAnnotations(), RequestMapping.class, GetMapping.class, PostMapping.class);
                if (null == anno1) return;

                String[] path0 = new String[0];
                String[] path1 = new String[0];
                try {
                    path0 = null == anno0 ? new String[] {} : Struct.call(anno0, String[].class, "value");
                    path1 = Struct.call(anno1, String[].class, "value");
                } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException e) {
                    e.printStackTrace();
                }

                if (0 == path1.length) return;

                for (String p0 : path0) {
                    for (String p1 : path1) {
                        String path = "/" + p0 + "/" + p1;
                        while (path.contains("//"))
                            path = path.replace("//", "/");
                        while (path.endsWith("/"))
                            path = path.substring(0, path.length() - 1);

                        System.out.println(path);
                    }
                }
            }
        });

异步工具库对异步执行操作做了优化，对系统整体性能有较好的提升。

// 异步执行
Task.async(() -> {
    System.out.println(Thread.currentThread().getName() + ": " + System.currentTimeMillis());
});
// 延迟任务
Task.delay(() -> {
    System.out.println(Thread.currentThread().getName() + ": " + System.currentTimeMillis());
}, 1000L);
// 循环任务
Task.loop(() -> {
    System.out.println(Thread.currentThread().getName() + ": " + System.currentTimeMillis());
}, "0/2 * * * * ?");

Spring下的异步支持：

@Autowired
private ExecutorService pool;

for (int i = 0; i < 8; i++) {
    final int n = i;
    this.pool.submit(() -> {
        try {Thread.sleep(100L);}
        catch (InterruptedException e) {e.printStackTrace();}
        System.out.println(Thread.currentThread().getName() + ": " + n);
    });
}
this.pool.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);

数据结构访问：

System.out.println(Struct.get(new LinkedList<>(), "size")); // 0
System.out.println(Struct.call("123456", "substring", 1, 4)); // "234"

常量修改：

Struct.setFinalDouble(Double.class, "MAX_VALUE", 1.1D);
System.out.println(Double.MAX_VALUE); // 1.1

String s = "12345";
Struct.setFinalObject(s, "value", new char[] {'a', 'b', 'c', 'd', 'e'}); // "abcde"

dist(分布式)

目前支持基于Redis的实现。 主机选举：

@Autowired
private Dist dist;

this.dist.elect("Some-Topic", new Election() {
    @Override
    public void elected(String topic) {
        System.out.println("Elected");
    }
    @Override
    public void lost(String topic) {
        System.out.println("Lost");
    }
});

分布式锁：

@Autowired
private Dist dist;

String name = "123";
this.dist.lock(() -> {
    System.out.println(Thread.currentThread().getName() + ": " + System.currentTimeMillis());
    try { Thread.sleep(100L); }
    catch (InterruptedException e) { e.printStackTrace(); }
}, name， 3000L);

el(表达式)

实现基于Aviator和Freemarker，整体语法基本相同，默认注册了很多有用的工具函数，支持注册中文变量。

@Autowired
private EL el;
    
System.out.println(this.el.eval("now('yyyy/MM/dd HH/mm/ss.SSS')"));
System.out.println(this.el.eval("randomBoolean()"));
System.out.println(this.el.eval("randomInt()"));
System.out.println(this.el.eval("randomLong()"));
System.out.println(this.el.eval("randomFloat()"));
System.out.println(this.el.eval("randomDouble()"));
System.out.println(this.el.eval("length('abcde')")); // "5"
System.out.println(this.el.eval("indexOf('abcde', 'cd')")); // "2"
System.out.println(this.el.eval("lastIndexOf('abcde', 'cd')")); // "2"
System.out.println(this.el.eval("trim('  abcde')")); // "abcde"
System.out.println(this.el.eval("reverse('abcde')")); // "edcba"
System.out.println(this.el.eval("substring('abcde', 1, 3)")); // "bc"
System.out.println(this.el.eval("substring('abcde', 3)")); // "de"
System.out.println(this.el.eval("replace('abcde', 'c', 'm')")); // "abmde"
System.out.println(this.el.eval("split('abcde', 'c')[0]")); // "ab"
System.out.println(this.el.eval("if(1 > 0, 'g', 'l')")); // "g"
System.out.println(this.el.eval("ifblank('', 'abcd')")); // "abcd"
System.out.println(this.el.eval("ifblank('1234', 'abcd')")); // "1234"
System.out.println(this.el.eval("Math.PI")); // "3.141592653589793"
System.out.println(this.el.eval("Math.E")); // "2.718281828459045"
System.out.println(this.el.eval("Math.abs(-15)")); // "15"
System.out.println(this.el.eval("Math.sqrt(2)")); // "1.4142135623730951"
System.out.println(this.el.eval("'123' + 'abc'")); // "123abc"

lio(长连接)

实现基于TCP、Websocket、SocketIO、Redis。

@RunWith(SpringRunner.class)
@SpringBootTest(classes = {TestFomjarCoreApplication.class})
// 控制器定义
@LIOController
public class TestLIOSpring {
    // 请求数据
    @LIORequest
    public String accept(JSONObject json) {
        System.out.println("server received: " + json.toString());
        return json.toString();
    }
    // 连接事件
    @LIOConnect
    public void connect(LIO lio) {
        System.out.println(String.format("Client %s:%d connect", lio.remoteHost(), lio.remotePort()));
    }
    // 断连事件
    @LIODisconnect
    public void disconnect(LIO lio) {
        System.out.println(String.format("Client %s:%d disconnect", lio.remoteHost(), lio.remotePort()));
    }
    // 创建客户端发起请求
    @Test
    public void test() throws IOException, InterruptedException, URISyntaxException {
//        LIO lio = new TCPLIO(new Socket("127.0.0.1", 9001));
        LIO lio = new WebSocketLIO(new URI("ws://127.0.0.1:" + 9001 + "/hello?a=1&b=2"));
        while (!lio.isOpen()) {
            Thread.sleep(100L);
        }
        for (int i = 0; i < 3; i++) {
            lio.write("{\"hello\" : \"world!\"}");
            Thread.sleep(200L);
        }
        lio.close();
    }
}

mq(消息队列)

实现基于AliyunMQ和Redis。

@Autowired
private MQ mq;

// 消费
this.mq.consume("test", msg -> {
    System.out.println(msg.toString());
});
// 生产
for (int i = 0; i < 3; i++) {
    this.mq.produce(new MQMsg().tag("test").data("Hello world!"));
    Thread.sleep(200L);
}

oss(对象存储)

实现基于AliyunOSS和Minio。

@Autowired
private OSS oss;

long time = System.currentTimeMillis();
System.out.println(oss.upload("test-" + time + ".txt", ("hello world! " + time).getBytes())); // http://url

pio(进程IO)

进程读为异步、写为同步。

new PIO()
    .readInput(new PIOLineReader() {
        @Override
        public void readLine(String line) throws Exception {
            logger.info("[OUT] {}", line);
        }
    })
    .readError(new PIOLineReader() {
        @Override
        public void readLine(String line) throws Exception {
            logger.info("[ERR] {}", line);
        }
    })
    .startup("java -h")
    .await();