springboot 多线程_redis官方推荐：SpringBoot用这个，一键多线程

Lettuce是一个可伸缩的线程安全的Redis客户端，提供了同步，异步和响应式使用方式。 如果多线程避免阻塞和事务操作(如BLPOP和MULTI / EXEC)，则多个线程可共享一个连接。 Lettuce使用通信使用netty。 支持先进的Redis功能，如Sentinel，群集，管道传输，自动重新连接和Redis数据模型。

下面分享来自网易后端工程师的Lettuce的使用心得~

de7b1c6c542246e8631eca8b3713df67.png

自己整理的Java架构学习视频和大厂项目底层知识点，需要的同学欢迎私信我【资料】发给你~一起学习进步！

Lettuce在Spring boot中的配置

 @Bean(name="clusterRedisURI")    RedisURI clusterRedisURI(){        return RedisURI.builder().withHost("xxx").withPort(6954).build();    }    @Bean    ClusterClientOptions clusterClientOptions(){        return ClusterClientOptions.builder().autoReconnect(true).maxRedirects(1024).build();    }    @Bean    RedisClusterClient redisClusterClient(ClientResources clientResources, ClusterClientOptions clusterClientOptions, RedisURI clusterRedisURI){        RedisClusterClient redisClusterClient= RedisClusterClient.create(clientResources,clusterRedisURI);        redisClusterClient.setOptions(clusterClientOptions);        return redisClusterClient;    } @Bean(destroyMethod = "close")    StatefulRedisClusterConnection statefulRedisClusterConnection(RedisClusterClient redisClusterClient){        return redisClusterClient.connect();    }

基本的使用方式

 @Bean(name="clusterRedisURI")    RedisURI clusterRedisURI(){        return RedisURI.builder().withHost("xxx").withPort(6954).build();    }    @Bean    ClusterClientOptions clusterClientOptions(){        return ClusterClientOptions.builder().autoReconnect(true).maxRedirects(1024).build();    }    @Bean    RedisClusterClient redisClusterClient(ClientResources clientResources, ClusterClientOptions clusterClientOptions, RedisURI clusterRedisURI){        RedisClusterClient redisClusterClient= RedisClusterClient.create(clientResources,clusterRedisURI);        redisClusterClient.setOptions(clusterClientOptions);        return redisClusterClient;    } @Bean(destroyMethod = "close")    StatefulRedisClusterConnection statefulRedisClusterConnection(RedisClusterClient redisClusterClient){        return redisClusterClient.connect();    }

集群模式

 @Bean(name="clusterRedisURI")    RedisURI clusterRedisURI(){        return RedisURI.builder().withHost("xxx").withPort(6954).build();    }    @Bean    ClusterClientOptions clusterClientOptions(){        return ClusterClientOptions.builder().autoReconnect(true).maxRedirects(1024).build();    }    @Bean    RedisClusterClient redisClusterClient(ClientResources clientResources, ClusterClientOptions clusterClientOptions, RedisURI clusterRedisURI){        RedisClusterClient redisClusterClient= RedisClusterClient.create(clientResources,clusterRedisURI);        redisClusterClient.setOptions(clusterClientOptions);        return redisClusterClient;    } @Bean(destroyMethod = "close")    StatefulRedisClusterConnection statefulRedisClusterConnection(RedisClusterClient redisClusterClient){        return redisClusterClient.connect();    }

客户端订阅事件

客户端使用事件总线传输运行期间产生的事件;EventBus可以从客户端资源进行配置和获取，并用于客户端和自定义事件。　　

如下事件可以被客户端发送:

  • 连接事件
  • 测量事件 (Lettuce命令延迟测量(CommandLatency))
  • 集群拓扑事件

订阅所有事件,并将事件输出到控制台

client.getResources().eventBus().get().subscribe(e -> {            System.out.println("client 订阅事件： " + e);        });

输出到内容有:

client 订阅事件： ConnectionActivatedEvent [/xx:49910 -> /xx:6008]client 订阅事件： ConnectionActivatedEvent [/xx:49911 -> /xx:6018]client 订阅事件： ConnectedEvent [/xx:49912 -> /xx:6018]

发布事件

用户除了可以通过事件总线订阅事件外还可以通过事件总线发布自定义事件

eventBus.publish(new Event() {           @Override           public String toString() {               return "自定义事件";           }       });

订阅到到内容如下:

client 订阅事件： 自定义事件

读写分离

lettuce master/slave模式支持读写分离,下面看看具体使用方式,只需要指定ReadFrom就可以了

@Bean(destroyMethod = "close")    StatefulRedisMasterSlaveConnection statefulRedisMasterSlaveConnection(RedisClient redisClient, RedisURI redisURI) {        StatefulRedisMasterSlaveConnection connection = MasterSlave.connect(redisClient, new Utf8StringCodec(), redisURI);        connection.setReadFrom(ReadFrom.NEAREST);        return connection;    }}

ReadFrom可选参数以及含义：

参数含义

MASTER

从master节点读取

SLAVE

从slave节点读取

MASTER_PREFERRED

从master节点读取,如果master节点不可以则从slave节点读取

SLAVE_PREFERRED

从slave节点读取,如果slave节点不可用则倒退到master节点读取

NEAREST

从最近到节点读取

下面看看源码是如何实现读写分离的,

//根据意图获取连接   public StatefulRedisConnection getConnection(Intent intent) {        if (debugEnabled) {           logger.debug("getConnection(" + intent + ")");       }       //如果readFrom不为null且是READ       if (readFrom != null && intent == Intent.READ) {           //根据readFrom配置从已知节点中选择可用节点描述           List selection = readFrom.select(new ReadFrom.Nodes() {               @Override               public List getNodes() {                   return knownNodes;               }                @Override               public Iterator iterator() {                   return knownNodes.iterator();               }           });           //如果可选择节点集合为空则抛出异常           if (selection.isEmpty()) {               throw new RedisException(String.format("Cannot determine a node to read (Known nodes: %s) with setting %s",                       knownNodes, readFrom));           }           try {               //遍历所有可用节点               for (RedisNodeDescription redisNodeDescription : selection) {                   //获取节点连接                   StatefulRedisConnection readerCandidate = getConnection(redisNodeDescription);                   //如果节点连接不是打开到连接则继续查找下一个连接                   if (!readerCandidate.isOpen()) {                       continue;                   }                   //返回可用连接                   return readerCandidate;               }               //如果没有找到可用连接，默认返回第一个               return getConnection(selection.get(0));           } catch (RuntimeException e) {               throw new RedisException(e);           }       }       //如果没有配置readFrom或者不是READ 则返回master连接       return getConnection(getMaster());   }

自定义负载均衡

通过上文的读写分离实现代码可以发现,只需要readFrom select方法每次返回的list都是随机无序的就可以实现随机的负载均衡

public class Sharded< C extends StatefulRedisConnection,V> {     private TreeMap nodes;    private final Hashing algo = Hashing.MURMUR_HASH;    private final Map resources = new LinkedHashMap<>();    private RedisClient redisClient;    private String password;    private Set sentinels;    private RedisCodec codec;     public Sharded(List masters, RedisClient redisClient, String password, Set sentinels, RedisCodec codec) {        this.redisClient = redisClient;        this.password = password;        this.sentinels = sentinels;        this.codec = codec;        initialize(masters);    }     private void initialize(List masters) {        nodes = new TreeMap<>();         for (int i = 0; i != masters.size(); ++i) {            final String master = masters.get(i);            for (int n = 0; n < 160; n++) {                nodes.put(this.algo.hash("SHARD-" + i + "-NODE-" + n), master);            }            RedisURI.Builder builder = RedisURI.builder();            for (HostAndPort hostAndPort : sentinels) {                builder.withSentinel(hostAndPort.getHostText(), hostAndPort.getPort());            }             RedisURI redisURI = builder.withPassword(password).withSentinelMasterId(master).build();            resources.put(master, MasterSlave.connect(redisClient, codec, redisURI));        }     }     public StatefulRedisConnection getConnectionBy(String key) {        return resources.get(getShardInfo(SafeEncoder.encode(key)));    }     public Collection getAllConnection(){        return Collections.unmodifiableCollection(resources.values());    }     public String getShardInfo(byte[] key) {        SortedMap tail = nodes.tailMap(algo.hash(key));        if (tail.isEmpty()) {            return nodes.get(nodes.firstKey());        }        return tail.get(tail.firstKey());    }      public void close(){       for(StatefulRedisConnection connection:  getAllConnection()){            connection.close();        }    }     private static  class SafeEncoder {          static byte[] encode(final String str) {            try {                if (str == null) {                    throw new IllegalArgumentException("value sent to redis cannot be null");                }                return str.getBytes("UTF-8");            } catch (UnsupportedEncodingException e) {                throw new RuntimeException(e);            }        }    }    private interface Hashing {        Hashing MURMUR_HASH = new MurmurHash();         long hash(String key);         long hash(byte[] key);    }      private static  class MurmurHash implements Hashing {          static long hash64A(byte[] data, int seed) {            return hash64A(ByteBuffer.wrap(data), seed);        }           static long hash64A(ByteBuffer buf, int seed) {            ByteOrder byteOrder = buf.order();            buf.order(ByteOrder.LITTLE_ENDIAN);             long m = 0xc6a4a7935bd1e995L;            int r = 47;             long h = seed ^ (buf.remaining() * m);             long k;            while (buf.remaining() >= 8) {                k = buf.getLong();                 k *= m;                k ^= k >>> r;                k *= m;                 h ^= k;                h *= m;            }             if (buf.remaining() > 0) {                ByteBuffer finish = ByteBuffer.allocate(8).order(ByteOrder.LITTLE_ENDIAN);                // for big-endian version, do this first:                // finish.position(8-buf.remaining());                finish.put(buf).rewind();                h ^= finish.getLong();                h *= m;            }             h ^= h >>> r;            h *= m;            h ^= h >>> r;             buf.order(byteOrder);            return h;        }         public long hash(byte[] key) {            return hash64A(key, 0x1234ABCD);        }         public long hash(String key) {            return hash(SafeEncoder.encode(key));        }    }    }

来源：网易工程师--张伟

有任何问题欢迎留言交流~

整理总结不易，如果觉得这篇文章有意思的话，欢迎转发、收藏，给我一些鼓励~

有想看的内容或者建议，敬请留言！

最近利用空余时间整理了一些精选Java架构学习视频和大厂项目底层知识点，需要的同学欢迎私信我发给你~一起学习进步！有任何问题也欢迎交流~

Java日记本，每日存档超实用的技术干货学习笔记，每天陪你前进一点点~

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/340009.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

oracle查询最高一条记录,oracle 查询已有记录，上一条记录,下一条记录

oracle查询最高一条记录,oracle 查询已有记录，上一条记录,下一条记录

oracle可以使用 lead、lag 函数来查询已有记录的下一条、上一条记录。表结构如下&#xff1a;如要查询Staffno是6-1102的前一条记录select * from staff where staff_no(select c.p from (select staff_no,lag(staff_no,1,0) over (order by staff_no) as p from staff) c wh…
阅读更多...
使用Maven进行增量构建

使用Maven进行增量构建

这是2020年&#xff0c;如果您要启动任何新的基于Java的项目&#xff0c;则应优先选择gradle&#xff0c;但由于某些原因&#xff0c;如果您仍然对Maven感兴趣&#xff0c;那么您可能会发现这篇文章有用。 Maven Java / scala编译器插件对增量编译提供了不错的支持&#xff0c…
阅读更多...
php删除菜单栏,如何删除WordPress站点健康状态面板和菜单项

php删除菜单栏,如何删除WordPress站点健康状态面板和菜单项

下面由WordPress教程栏目给大家介绍删除WordPress站点健康状态面板和菜单项的方法&#xff0c;希望对需要的朋友有所帮助&#xff01;删除 WordPress 站点健康状态面板和菜单项WordPress站点健康功能始于 5.2 版&#xff0c;如不想显示这玩意&#xff0c;可以使用本文的方法删除…
阅读更多...
colspan会影响内部单元格宽度失效_电感失效分析

colspan会影响内部单元格宽度失效_电感失效分析

电感失效分析01电感的作用我们通常所说的电感指的是电感器件&#xff0c;它是用绝缘导线(例如漆包线,沙包线等)绕制而成的电磁感应元件。在电路中&#xff0c;当电流流过导体时&#xff0c;会产生电磁场&#xff0c;电磁场的大小除以电流的大小就是电感。电感是衡量线圈产生电磁…
阅读更多...
ZeptoN正在将程序放入Java

ZeptoN正在将程序放入Java

1.简介 Java编程语言或“ Java”于1995年引入。然而&#xff0c;在近25年的时间里&#xff0c;它增加了最初不是核心语言所具有的功能。 此类功能包括枚举&#xff0c;泛型&#xff0c;对基本C样式功能开关语句的许多增强&#xff0c;断言等。 Java是一种编程语言&#xff0c;随…
阅读更多...
Quarkus入门

Quarkus入门

Quarkus – 一个为OpenJDK HotSpot和GraalVM量身定制的Kubernetes本机Java堆栈&#xff0c;它是从最佳Java库和标准中精制而成的。 –是一个容器优先的框架&#xff0c;针对快速启动时间和低内存消耗进行了优化。 该框架基于许多流行的Java库构建&#xff0c;并且为构建标准RES…
阅读更多...
vmware6.5.2序列号_教你如何查询苹果序列号，查询是否为官换机、激活时间等

vmware6.5.2序列号_教你如何查询苹果序列号，查询是否为官换机、激活时间等

如何查询你刚买的苹果设备是否为官换机&#xff1f;或想知道它的激活日期&#xff1f;保修时间&#xff1f;那么赶紧收藏本篇教程吧&#xff01;众所周知&#xff0c;在苹果官网查询苹果设备&#xff0c;是查询不到具体的信息&#xff08;比如激活日期、保修日期、是否为官换机…
阅读更多...
linux 7启动文件夹在哪里设置密码,RHEL7 or CentOS7 的系统密码如何重置

linux 7启动文件夹在哪里设置密码,RHEL7 or CentOS7 的系统密码如何重置

导读RHEL7 的世界发生了变化&#xff0c;重置 root 密码的方式也一样。虽然中断引导过程的旧方法(init/bin/bash)仍然有效&#xff0c;但它不再是推荐的。“Systemd” 使用 “rd.break” 来中断引导。让我们快速浏览下整个过程。介绍目的在 RHEL7/CentOS7/Scientific Linux 7 中…
阅读更多...
里氏替换原则_代码需要有单一职责，还要开闭，里氏替换又是什么鬼？

里氏替换原则_代码需要有单一职责，还要开闭，里氏替换又是什么鬼？

目录单一职责原则&#xff1a;开闭原则&#xff1a;里氏替换原则&#xff1a;单一职责原则&#xff1a;每一个系统中的功能都表示一个职责&#xff0c;这些职责可以映射到模块&#xff08;类&#xff09;中&#xff0c;且尽可能的保证这些类中没有功能上的重复&#xff0c;设计…
阅读更多...
联想打印机7256显示更换墨盒_惠普打印机涉嫌垄断？只认自家“昂贵”墨盒，成本太高招架不住...

联想打印机7256显示更换墨盒_惠普打印机涉嫌垄断？只认自家“昂贵”墨盒，成本太高招架不住...

近日&#xff0c;有人爆料称&#xff0c;所在公司购买的惠普打印机使用原装墨盒时可正常打印&#xff0c;更换其他品牌墨盒后也不能正常使用&#xff0c;因此认为惠普公司有行业垄断的嫌疑。从细节来看&#xff0c;该公司购买了惠普同一型号但不同批次的两台打印机&#xff0c;…
阅读更多...
linux mcelog 运行,服务器硬件检测（采用mcelog）

linux mcelog 运行,服务器硬件检测（采用mcelog）

mt 内存监控&#xff1a;mcecheck.pyraid监控&#xff1a; check-raidmcelog 是 x86 的 Linux 系统上用来检查硬件错误&#xff0c;特别是内存和CPU错误的工具。安装方式yum install mcelog运行mcelog查看日志方式/var/log/mcelogMCE 0HARDWARE ERROR. This is NOT a software …
阅读更多...
动手选择值

动手选择值

由于冠状病毒的存在&#xff0c;可选的东西在空中&#xff0c;一切都变得可选&#xff0c;例如可选的公共聚会&#xff0c;可选的在家工作&#xff0c;可选的旅行等。 我现在是时候谈论处理NULL引用的软件工程中真正的“ 可选 ”了。 托尼霍尔&#xff08;Tony Hoare&#xf…
阅读更多...
wincc历史数据库_WinCC系统的基本功能介绍——自动化工程师必备

wincc历史数据库_WinCC系统的基本功能介绍——自动化工程师必备

写在面前前面讲解了西门子的TIA Portal Wincc, Wincc Classic和Wincc OA (一文带你了解西门子Wincc),介绍了西门子的超大型/分布式SCADA系统Wincc OA(初识西门子Wincc OA——超大型/分布式SCADA)&#xff0c;还介绍了Wincc Classic的典型架构和选型指南(WinCC V7.5典型架构及选…
阅读更多...
apache.camel_Apache Camel 2.14中的更多指标

apache.camel_Apache Camel 2.14中的更多指标

apache.camelApache Camel 2.14将于本月晚些时候发布。 由于正在解决某些Apache基础结构问题&#xff0c;因此存在一些问题。 这篇博客文章讨论的是我们添加到此版本中的新功能之一。 感谢Lauri Kimmel捐赠了骆驼指标组件&#xff0c;我们将其与出色的Codehale指标库集成在一起…
阅读更多...
依赖管理和Maven

依赖管理和Maven

Maven伟大而成熟。 几乎所有事物都总有解决方案。 您可能在组织项目上遇到的主要情况是依赖管理。 而不是每个项目都没有自己的依赖关系&#xff0c;您需要一种集中化的方式来继承那些依赖关系。 在这种情况下&#xff0c;您可以在父舞会上声明托管依赖项。 在我的示例中&…
阅读更多...
linux ps 代码,Linux ps命令详解(示例代码)

linux ps 代码,Linux ps命令详解(示例代码)

ps命令是Process Status的缩写, 用来列出系统中当前运行的那些进程. ps命令列出的是当前那些进程的快照&#xff0c;就是执行ps命令的那个时刻的那些进程&#xff0c;如果想要动态的显示进程信息&#xff0c;就可以使用top命令ps常见命令参数********* simple selection ******…
阅读更多...
Apache Kafka消费者再平衡

Apache Kafka消费者再平衡

消费者重新平衡决定哪个消费者负责某些主题的所有可用分区的哪个子集。 例如&#xff0c;您可能有一个包含20个分区和10个使用者的主题。 在重新平衡结束时&#xff0c;您可能希望每个使用者都从2个分区中读取数据。 如果关闭了这些使用者中的10个&#xff0c;则可能会期望每个…
阅读更多...
linux系统ll历史,Linux操作系统原理笔记

linux系统ll历史,Linux操作系统原理笔记

在Linux操作系统内核内部&#xff0c;进程是通过一个链表&#xff0c;而且是一个双向链表来管理的。进程描述符&#xff1a;每一个进程都有其描述符&#xff0c;每一个描述符彼此之间都有关联性的。双向链表&#xff1a;一个进程内部可能包含多个线程。上下文切换(Context swtc…
阅读更多...
java工程师的终极书单_Java 9 –终极功能列表

java工程师的终极书单_Java 9 –终极功能列表

java工程师的终极书单这篇文章将针对即将到来的Java 9版本进行更新&#xff0c;新增功能 &#xff08; 最新更新&#xff1a;2014年 9月9日 &#xff09; OpenJDK开发正在加快速度&#xff1a;2014年3月Java 8发布后&#xff0c;我们预计将进入2年的发布周期。 据报道&#xf…
阅读更多...
称之为例外？

称之为例外？

尽管这是一个与测试和Wiremock有关的Java示例&#xff0c;但它涉及一个更普遍的问题。 我们正在尝试重试Wiremock的verify方法&#xff0c;该方法可能会在我们要检查的端点被命中之前由测试调用。 在这种情况下&#xff0c;我们想在几秒钟后重试一次直到超时。 有趣的是&#…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023