发布时间：2018-09-14 16:24:31

前面一篇AMQ专题中，我们发现对于Topic这种类型的消息，即使将deliveryMode设置为持久化，只要生产者在消费者之前启动。消息生产者发布的消息还是会丢失。这是符合JMS规范的。而所谓的deliveryMode持久化和订阅持久化还是两个不同的概念。本篇博客我们就通过实例来一探究竟。在前面一篇中，我们通过producer.setD.........【阅读全文】

发布时间：2018-09-13 15:03:19

通过 HashMap、HashSet 的源代码分析其 Hash 存储机制在介绍集合存储之前需要指出一点：虽然集合号称存储的是 Java 对象，但实际上并不会真正将 Java 对象放入 Set 集合中，只是在 Set 集合中保留这些对象的引用而言。也就是说：Java 集合实际上是多个引用变量所组成的集合，这些引用变量指向实际的 Java 对象。.........【阅读全文】

发布时间：2018-09-12 16:07:56

ActiveMQ中的BrokerService使用jconsole了解嵌入ActiveMQ运行状态在pom.xml添加ActiveMQ依赖，本次代码实例采用5.7版本，记住只需要activemq-core就行。<dependency> <groupId>org.apache.activemq</groupId> <artifactId>activemq-core</artifactId> <version>5.7.0</version></dependency>.........【阅读全文】

发布时间：2018-09-11 16:35:06

Flink内置引擎是一个分布式流数据流引擎，支持 流处理和批处理 ，支持和使用现有存储和部署基础架构的能力，它支持多个特定于域的库，如用于机器学习的FLinkML、用于图形分析的Gelly、用于复杂事件处理的SQL和FlinkCEP。Flink的另一个有趣的方面是现有的大数据作业（Hadoop M / R，Cascading，Storm）可以 .........【阅读全文】

发布时间：2018-09-10 20:14:05

1 Java7 HashMap通过查看 JDK 中的 HashMap 源码，可以看到其构造函数有一行代码：public HashMap(int initialCapacity, float loadFactor) { ... table = new Entry[capacity]; ...}可以看到，Entry 是一个 static class，其中包含了 key 和 value ，也就是键值对，另外还包含了一个 next 的.........【阅读全文】