本文是由链博科技 ChainBoard.IO 为大家带来的web3j 对智能合约的调用。让 java 程序可以和我们的智能合约愉快的交互起来~ 一、什么是 web3j web3j是一个高度模块化、响应式、类型安全的Java和Android库，用于与智能合约交互，并与Ethereum网络的客户端(节点)集成。 二、准备工作 1.新建一个spring-boot的项目，在 pom 文件中添加 <dependency> <groupId>org.web3j</groupId> <artifactId
本文是由链博科技 ChainBoard.IO 为大家带来的web3j 对智能合约的调用。让 java 程序可以和我们的智能合约愉快的交互起来~ 一、 什么是 web3j web3j是一个高度模块化、响应式、类型安全的Java和Android库，用于与智能合约交互，并与Ethereum网络的客户端(节点)集成。 二、准备工作 1.新建一个spring-boot的项目，在 pom 文件中添加 <dependency> <groupId>org.web3j</groupId> <artifac
上述代码中，Computable接口定义的是一类用于执行某种类型计算的策略族。ExpensiveFunction实现了Computable接口，该类在概念上是通过传入的参数arg，经过一系列复杂计算而得到结果，这里为了方便起见，只是返回了一个BigInteger对象。Memorizer1类也实现了Computable接口，这里实际上用到了装饰者模式，在构造Memorizer1类时需要传入一个Computable类型对象进来，如ExpensiveFunction，当需要使用ExpensiveFunction类来进行复杂计算时，可以通过Memorizer1类来对其进行装饰，转而调用Memorizer1的compute方法。而在Memorizer1内部，其使用了一个HashMap来对真正的Computable对象（如ExpensiveFunction）的结果进行了缓存，如果传入的参数arg能够在cache中找到结果，那么直接返回，否则调用实际的Computable::compute方法进行计算，通过这种方式达到提高系统新能的目的。
Description of Java Conceptual Diagram（java结构）
本文中，我们举例来说明如何使用JClouds API 获取和发布云服务器。JClouds API 可以和大量云服务提供商（包括Amazon EC2和Rackspace）协同工作并且允许使用Java代码执行大量操作。换句话说，JClouds API不是针对某些提供商所特定接口去进行交互。下面我们以Rackspace所提供的云服务为例进行说明。
//此文基于《Java并发编程实践》 我们都知道在应用程序中合理地使用缓存，能更快的访问我们之前的计算结果，从而提高吞吐量。例如Redis和Memcached基于内存的数据存储系统等。此篇文章介绍如何实现简单缓存。 首先定义一个Computable接口A是输入，V是输出。 1 package simplecache; 2 3 /** 4 * Created by yulinfeng on 12/25/16. 5 */ 6 public interface Computable<A, V> { 7
我用的本地 windows 环境访问的飞腾服务器，这个服务器里的系统是不支持图像化界面的，需要通过 display 指定自己的电脑来显示图像化界面。 命令如下，这个 ip 是对应自己电脑的，通过 ipconfig 可以查看，示例中的 ip 是 10.10.10.10。
最近发现业务上返回慢，并且feign的fallback被触发了。查看日志，发现触发了重试，是什么触发的重试呢，通过异常堆栈发现：
在HDFS集群中NameNode存在单点故障（SPOF），对于只有一个NameNode的集群，如果NameNode机器出现意外，将导致整个集群无法使用。为了解决NameNode单点故障的问题，Hadoop给出了HDFS的高可用HA方案，HDFS集群由两个NameNode组成，一个处于Active状态，另一个处于Standby状态。Active NameNode可对外提供服务，而Standby NameNode则不对外提供服务，仅同步Active NameNode的状态，以便在Active NameNode失败时快速的进行切换。本篇文章Fayson主要讲述如何使用Cloudera Manager启用HDFS的HA。
尽管Java的内置异常处理大多数常见错误，你也许希望建立你自己的异常类型来处理你所应用的特殊情况。这是非常简单的：只要定义Exception的一个子类就可以了（Exception当然是Throwable的一个子类）。你的子类不需要实际执行什么——它们在类型系统中的存在允许你把它们当成异常使用。
《玩转Java并发工具、精通JUC、成为并发多面手》构建高性能缓存这部分的个人笔记。本节为单纯的实战，主要是把之前学习并发编程的知识点串起来。
先更新一下下载源。用17.04 的源可以解决在18.04中找不到libjasper.dev的问题。
在Impala 4.0源码解析之BROADCAST/SHUFFLE代价计算这篇文章中我们提到，Impala在对BROADCAST/SHUFFLE进行代价计算的时候，需要用到表的统计信息。关于Impala的统计信息，网上也有一些资料介绍，但是大多不全。本文将结合官方文档，从内容、计算等各方面尽可能详细地介绍下Impala统计信息的相关知识。
web3j 是一个针对java的开发工具。web3j command line 可以用来创建钱包、转账、查询余额以及包括智能合约编译、根据智能合约生成对应的java文件。
对于简单的并行任务，你可以通过“线程池+Future”的方案来解决；如果任务之间有聚合关系，无论是AND聚合还是OR聚合，都可以通过CompletableFuture来解决；而批量的并行任务，则可以通过CompletionService来解决。这几种方案基本上能够覆盖日常工作中的并发场景了，但还是不够全面，因为还有一种“分治”的任务模型没有覆盖到。
在之前文章说到，简单 if-else，可以使用 卫语句 进行优化。但是在实际开发中，往往不是简单 if-else 结构，我们通常会不经意间写下如下代码：
ForkJoinPool 是一个功能强大的 Java 类，用于处理计算密集型任务，使用 ForkJoinPool 分解计算密集型任务，并并行执行它们，能够产生更好的性能。它的工作原理是将任务分解成更小的子任务，使用分而治之的策略进行操作，使其能够并发地执行任务，从而提高吞吐量并减少处理时间。
值 Option 这个Option(vavr)或Optional(java8)就是提醒开发人员这个值有可能为null，你在使用前进行判空处理。 在Java8中也就是我们上面所描述的Optional。 Vavr 中的 Option 与 Java 8 中的 Optional 是相似的。不过 Vavr 的 Option 是一个接口，有两个实现类 Option.Some 和 Option.None，分别对应有值和无值两种情况。Option 也支持常用的 map、flatMap 和 filter 等操作. /**
JDK是在一直在迭代更新的，很多我们熟悉的类也悄悄的添加了一些新的方法特性。比如我们最常用的HashMap。
在CDH集群中Clouder Manager、Cloudera Navigator、Hue、CDSW等组件支持外部身份验证的方式登录（如：Active Directory、LDAP、外部程序以及SAML），本篇文章主要介绍如何使用Shibboleth项目搭建一个基于标注SAML协议实现的IDP服务并集成OpenLDAP。
一，题目 Instruction: Please complete the following task. Use whatever tools you find appropriate (using the Internet, for example, is assumed). Linux, C++, Python, CMake, Qt, and OpenCV are preferred for development but you may use other tools if you
文章开始的时候我就说了，这个方案的演进过程是按照《Java并发编程实战》的第 5.6 节的内容写的。
Kafka从0.8版本以后出了新的API接口，用于异步方式发送消息，性能优于旧的API，本篇文章主要使用新的API接口进行测试。继上一篇文章如何通过Cloudera Manager为Kafka启用Kerberos及使用，本篇文章主要讲述如何使用Java连接Kerberos的Kafka集群生产和消费消息。
前面Fayson介绍了《如何使用HAProxy实现HiveServer2负载均衡》，本文主要介绍如何使用HAProxy实现Kerberos环境下HiveServer2的负载均衡。
我是在mac上操作的. 先找到mac的java地址. 从~/.bash_profile中可以看到
本文档讲述如何开发Hive自定义函数（UDF），以及如何在Impala中使用Hive的自定义函数，通过本文档，您将学习到以下知识：
下面说明一下我的运行环境。我是在mac上操作的. 先找到mac的java地址. 从~/.bash_profile中可以看到
当类被@RunWith注解修饰，或者类继承了一个被该注解修饰的类，JUnit将会使用这个注解所指明的运行器（runner）来运行测试，而不使用JUnit默认的运行器。
ForkJoin框架是Java并发包(java.util.concurrent)的一部分，主要用于并行计算，特别适合处理可以递归划分成许多子任务的问题，例如大数据处理、并行排序等。该框架的核心思想是将一个大任务拆分成多个小任务（Fork），然后将这些小任务的结果汇总起来（Join），从而达到并行处理的效果。
在前面的文章《CDH5.13和CM5.13的新功能》中Fayson介绍过Cloudera发布CDH5.13时，同时也发布了Kafka3.0版本（即社区0.11版），目前社区最新版本为1.0。由于Kafka3.0和Spark2.2需要JDK8的支持，所以在升级Kafka3.0和Spark2.2版本时必须先升级JDK版本，可以参考《如何将CDH集群JAVA升级至JDK8》和《如何将Kerberos环境下CDH集群JAVA升级至JDK8》，本文Fayson主要介绍在CDH集群中如何升级Kakfa3.0和Spark2.2。
统计List集合中元素出现的次数，相信大家都做过。举个例子，我们要统计集合中名字重复的次数。
同样的java代码在不同平台生成的机器码肯定是不一样的，因为不同的操作系统底层的硬件指令集是不同的。
安装SparkR颇费周折，网上看到的各种安装方法，其实最终测试都很不好用。可能是国内有些网站被屏蔽的关系吧。
Fork-Join是什么？ Fork-Join是Java的一个并行框架，主要的作用是将大任务分解为多个小任务，交由多个工作线程运行，最后将小任务的计算结果汇总，得到大任务的结果。
使用Hue可以方便的通过界面制定Oozie的工作流，支持Hive、Pig、Spark、Java、Sqoop、MapReduce、Shell等等。Spark？那能不能支持Spark2的呢，接下来本文章就主要讲述如何使用Hue创建Spark1和Spark2的Oozie工作流。
转自：java并发编程实战 5.3阻塞队列和生产者-消费者模式 BlockingQueue阻塞队列提供可阻塞的put和take方法，以及支持定时的offer和poll方法。如果队列已经满了，那么put方法将阻塞直到空间可用；如果队列为空，那么take方法将阻塞直到有元素可用。队列可以是有界的也可以是无界的。 如果生产者生成工作的速率比消费者处理工作的速率款，那么工作项会在队列中累计起来，最终好紧内存。同样，put方法的阻塞特性也极大地简化了生产者的编码。如果使用有界队列，当队列充满时，生产者将阻塞并不能继续
来源：https://juejin.im/post/6844903983744548877
本篇是Typing相关知识的最后一篇。介绍关于类型的闭包和类型推断关系，以及最终的类型静态编译相关知识点。
2019年4月15日，Cloudera在其官网宣布GA两款新的产品Cloudera Flow Management和Cloudera Edge Management，即CFM和CEM。Flow Management和Edge Management以前都是隶属于HDP的相关产品，Cloudera此次官宣代表的是它们现在可以与CDH一起安装并使用，包括使用Cloudera Manager进行简易的Parcel安装和服务监控。HDP和CDH合并后，对于CDH的客户也一直期待HDP的一些优秀特性能早点融合到CDH中，CEM和CFM就是一次开始，它们为IOT场景的边缘管理和边缘数据搜集带来了可能。具体参考《0603-Cloudera Flow Management和Cloudera Edge Management正式发布》。
使用DelayQueue、ConcurrentHashMap、FutureTask实现的缓存工具类。 DelayQueue 简介 DelayQueue是一个支持延时获取元素的无界阻塞队列。DelayQueue内部队列使用PriorityQueue来实现。队列中的元素必须实现Delayed接口，在创建元素时可以指定多久才能从队列中获取当前元素。只有在延迟期满时才能从队列中提取元素。 DelayQueue非常有用，可以将DelayQueue运用在以下应用场景。 缓存系统的设计：可以用DelayQueue保存缓存
DataTable中数据记录的统计我们在使用SqlServer这些数据库时，可以轻松的通过SumC#
Label label = new Label() 这个语句中，label的作用是为了条件跳转，其实也可以理解成字节码指令的参数。 所以label必须对应一条字节码指令，通过visitLabel(label)来调用，并且visitLabel的调用必须紧跟随着label对象指定的指令。 如例子中，第一个label指向goto后，所以顺序必须是：mv.visitJumpInsn(Opcodes.GOTO, end);
通过上一篇《Spring Cloud构建微服务架构：服务注册与发现》，我们已经成功地将服务提供者：compute-service服务注册到Eureka服务注册中心或Consul服务端上了，那么我们要如何去消费服务提供者的接口呢？ Spring Cloud Ribbon Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端负载均衡的工具。它是一个基于HTTP和TCP的客户端负载均衡器。它可以通过在客户端中配置ribbonServerList来设置服务端列表去轮询访问以达到均
在我们平常开发过程中，由于项目时间紧张，代码可以用就好，往往会忽视代码的质量问题。甚至有些复制粘贴过来，不加以整理规范。往往导致项目后期难以维护，更别说后续接手项目的人。所以啊，我们要编写出优雅的代码，方便你我他，岂不美哉？
package com.lzw; import java.util.concurrent.ForkJoinPool; import java.util.concurrent.RecursiveAction; import java.util.concurrent.TimeUnit; /** * @作者 王梓 * 莫失莫忘 仙寿恒昌 * 2015年1月11日 * Email:277215243@qq.com */ public class Test extends RecursiveAction
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
