murmurhash3 学习笔记

简介: ## 背景 由于项目中有报文排重需求,所以会将报文字符串作为分布式锁key。 考虑到报文不定长并且散列性不太好,如其作为锁key,特别是当key值过大时,使用redis进行读写都会有相对的性能下降。 ``` 参考文献里测试对比: 长度为10:写平均耗时0.053ms,读0.040ms 长度为20000:写平均耗时0.352ms,读0.084ms ``` 一种简单的方案是

背景

由于项目中有报文排重需求,所以会将报文字符串作为分布式锁key。
考虑到报文不定长并且散列性不太好,如其作为锁key,特别是当key值过大时,使用redis进行读写都会有相对的性能下降。

参考文献里测试对比:
长度为10:写平均耗时0.053ms,读0.040ms
长度为20000:写平均耗时0.352ms,读0.084ms

一种简单的方案是对报文进行一次md5,然后拿来做key。
考虑到md5的性能并不高,找到了更合适的murmurhash3非加密哈希算法:

Screen Shot 2018-09-10 at 5.46.22 PM.png

算法图例

murmurhash_diagram.png

(可以看到里面有c1, c2, n 三个很特别的常量,据算法作者Austin Appleby讲,都是他血汗地用大量测试数据调测出来的,为了不被其他好事之徒当头一暴击,他保留继续微调的权利。)

参考文档里都说murmurhash3棒棒的,但是不实践下还是不能随意拿来进献给Boss, 我找了一个代码,做了一个性能对比,测试使用了Google的guava里的Hashing.murmur3_32(),对比apache的commons-lang3的md5Hex算法。

测试源码

public class HashTest {

    public static String md5Test(String primaryKey) {
        return DigestUtils.md5Hex(primaryKey).substring(0, 4) + "_" + primaryKey;
    }

    public static String murmur3Test(String primaryKey) {
        return Hashing.murmur3_32().hashString(primaryKey, StandardCharsets.UTF_8).toString().substring(0, 4) + 
            "_" + primaryKey;
    }
}

跑测试源码如下(为方便直接用了Spock单测脚本):


@Unroll
class HashTestSpec extends Specification {

    def "HashTest md5 & murmurhash3"() {
        long startTime=System.currentTimeMillis()
        for (int i = 0; i < 10000; i++) {
            HashTest.md5Test(getRandomString(10))
        }
        long endTime=System.currentTimeMillis()
        print "1万次md5算法程序运行时间: " + (endTime - startTime ) + "ms"
        print "\n"

        long startTime2=System.currentTimeMillis()
        for (int i = 0; i < 10000; i++) {
            HashTest.murmur3Test(getRandomString(10))
        }
        long endTime2=System.currentTimeMillis()
        print "1万次murmurhash3算法程序运行时间: " + (endTime2 - startTime2 ) + "ms"
        expect:
        1==1
    }
}

对比测试结果:
1万次md5算法程序运行时间: 235ms
1万次murmurhash算法程序运行时间: 73ms

有4倍的差距。

按参考文档建议,换成murmur3_128,1万次murmurhash算法程序运行时间: 51ms, 果然更优秀。

getRandomString的参考代码也一并附上,方便好事之徒做复现。

    public static String getRandomString(int length){
        String str="abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789";
        Random random=new Random();
        StringBuffer sb=new StringBuffer();
        for(int i=0;i<length;i++){
            int number=random.nextInt(62);
            sb.append(str.charAt(number));
        }
        return sb.toString();
    }

参考

目录
相关文章
|
消息中间件 存储 NoSQL
|
机器学习/深度学习 算法 开发者
神经元模型|学习笔记
快速学习神经元模型
神经元模型|学习笔记
|
自然语言处理 前端开发 Java
TermQuery|学习笔记
快速学习 TermQuery。
138 0
TermQuery|学习笔记
|
机器学习/深度学习 算法 开发者
总结与回顾| 学习笔记
快速学习总结与回顾。
总结与回顾| 学习笔记
|
人工智能 开发者
一点一世界 | 学习笔记
快速学习一点一世界
一点一世界 | 学习笔记
|
存储 Java 开发者
BinaryTree|学习笔记
快速学习BinaryTree
BinaryTree|学习笔记
|
开发者
SearchType 详解|学习笔记
快速学习 SearchType 详解。
264 0
|
开发者 索引
MatchAllQuery|学习笔记
快速学习 MatchAllQuery。
128 0
|
XML 设计模式 JavaScript
回顾 | 学习笔记
快速学习回顾,介绍了回顾系统机制, 以及在实际应用过程中如何使用。
|
存储 编译器 C++
c++学习笔记之类
预处理器封套: #ifndef XXX_H #define XXX_H ... class xxx{ ... } ... #endif 复制代码 如果没有文件包含此头文件,XXX_H被定义并包含这个头文件;如果已经包含,则不再定义和包含。 为了防止多次包含同一个头文件,尤其包含套包含的时候。注意命名要大写和下划线。
122 0