【JVM源码探秘】JVM线程模型概览



HotSpot中的线程模型是Java线程(java.lang.Thread)与本地操作系统线程一一映射,本地线程在Java线程启动(调用start())时创建, 并在终止时回收。操作系统负责调度本地线程给可用的CPU来执行。Java线程优先级和操作系统优先级之间的关系是相当复杂的,并且因操作系统而异。

Read More>>


【JVM源码探秘】细说Class.forName()底层实现



JVM允许在运行时动态装载类,这为开发者提供了极大方便,使用Class.forName("com.xxx.Xxx"), 装载完成后可以通过调用其newInstance()完成对象的创建,然后便可以正常操作该类。

接下来我们就细说说Class.forName()在JVM层面所做的事情。

Read More>>

集群架构中的异步回调模型实现



团队中前些天遇到这样一个问题,比较有意思也比较典型,我给出方案后团队成员实施出来,最终问题得以解决。 > 一个智能终端连接到Netty服务保持会话,在异步完成某项操作后回调回来需要通过会话通知终端,终端再根据通知做相应业务处理, > 在部署单节点的情况下是OK的,但是系统整体由于要做HA,部署多节点后就会出现问题: 并不能保证该回调请求一定负载到终端保持会话的节点

如何解决这个问题?这里跟大家分享一种类似场景的通用解决方案,以下是流程图:

                            < Async Callback Model in Cluster Architecture >

                                              (D) Broadcast to all nodes
                              +-----------------------------------------------------------------------+
                              v                                                                       |
                          + - - - - - - - - - +
                          ' Cluster:          '
                          '                   '
+--------+  (A) Connect   ' +---------------+ '  (B) Async call   +---------------+  (C) Callback   +----+
|        | -------------> ' | Server Node A | ' ----------------> |               | --------------> |    |
|        |                ' +---------------+ '                   |               |                 |    |
|        |                '                   '                   |               |                 |    |
|        |                + - - - - - - - - - +                   |               |                 |    |
|        |  (E) Notify        :                                   |               |                 |    |
|        | <...................                                   |               |                 |    |
|        |                                                        |               |                 |    |
| Client |                + - - - - - - - - - +                   | Remote Server |                 | MQ |
|        |                '                   '                   |               |                 |    |
|        |                ' +---------------+ '                   |               |                 |    |
|        |                ' | Server Node B | '                   |               |                 |    |
|        |                ' +---------------+ '                   |               |                 |    |
|        |                ' +---------------+ '                   |               |                 |    |
|        |                ' | Server Node C | '                   |               |                 |    |
|        |                ' +---------------+ '                   |               |                 |    |
|        |                '                   '                   |               |                 |    |
+--------+                + - - - - - - - - - +                   +---------------+                 +----+

Read More>>

使用Python十行代码打造简单爬虫



今天从某网站上看到一些文档觉得还不错, 一共有300+篇,一个个手动下载?这简直是对一个程序员的侮辱。

怎么办呢,写个简单的爬虫吧。

BeautifulSoup是做爬虫的好手,requests是HTTP访问的强者,这里的Demo场景比较简单略显大材小用,

有效代码不超十行,十分简洁优雅,人生苦短,我用Python。

Read More>>

聊一聊使用多线程处理MQ消息的正确姿势



Q:有这样一个场景,MQ的生产者生产消息能力是消费者的数倍。 如果不能尽快消费完会导致队列中的消息随着时间的推移会越积越多,而且业务也无任何时效性可言, 那么问题来了,在不增加消费节点的前提下如何快速处理完消息以保证吞吐量?

面对以上问题,有人可能会信心满满地脱口而出:用多线程。OK,我只能说思路没错,那么如何落地呢?

Read More>>

【JVM源码探秘】深入registerNatives()底层实现



在Java的系统包下如:

  • java.lang.System
  • java.lang.Object
  • java.lang.Class

等类中均有一个静态块用来执行一个叫做registerNatives()的native方法,

    private static native void registerNatives();
    static {
        registerNatives();
    }

这个native方法里究竟都做了啥?我们进去瞧瞧。

Read More>>

【JVM源码探秘】深入System.gc()底层实现



对于Java语言来说是不用手动释放内存的,并且不需要手动干预JVM的GC行为,但在一些监控和agent工具里却是必要的。

Hotspot为我们开放了Java语言级别的GC手动触发入口System.gc(),本文将深入介绍JVM底层实现。

Read More>>