
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
我的博客要上线测试了,买的阿里云服务器,在装完redis后,项目和管理工具并不能连接上服务器上的redis,这是怎么回事。解决办法如下:1.开启防火墙:systemctl start firewalld.service2.添加端口:firewall-cmd --zone=public --add-port=6379/tcp --permanent3.重启防火墙:firewall-cmd --rel
一、什么是ik分词器分词:即把一段中文或者别的划分成一个个的关键字,我们在搜索时候会把自己的信息进行分词,会把数据库中或者索引库中的数据进行分词,然后进行一个匹配操作,默认的中文分词是每个字看成一个词,比如“我爱狂神”会被分为“我,“爱”,“狂”,“神”,这显然是不符合要求的,所以我们需要安装中文分词器ik来解决这个问题,IK提供了两个分词算法:ik_smart和ik_max_word,其中ik_
说明:高吞吐量、低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒;可扩展性:kafka集群支持热扩展;持久性、可靠性:消息被持久化到本地磁盘,并且支持数据备份防止数据丢失;容错性:允许集群中节点故障(若副本数量为n,则允许n-1个节点故障);高并发:支持数千个客户端同时读写。使用场景:日志收集:一个公司可以用Kafka可以收集各种服务的log,通过kafka以统一接口服务的方式开
注:上篇博客说了怎么搭建kafka集群,并实现springboot集成kafka实现消息单条消费,但是如果有场景需要批量消费,那么就需要对消费者进行配置了,并可以实现并发消费,即多个KafkaListener同时消费消息,以此达到批量消费和提高速度的目的。1.上消费者配置@Configuration@EnableKafkapublic class KafkaConsumerConfig {@Val
准备一个gateway微服务pom如下:<!-- SpringCloud Gateway --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></d
1.上篇讲了java里使用setNX实现redis分布式锁,可是这种方法还是有很多弊端的,追求完美的做法可以使用redisson来实现分布式锁,如下:2.Redisson 是 java 的 Redis 客户端之一,是 Redis 官网推荐的 java 语言实现分布式锁的项目。它提供了一些 api 方便操作 Redis。因为本文主要以锁为主,所以接下来我们主要关注锁相关的类,以下是 Redisson
Pulsar与Kafka一样是分布式消息中间件Pulsar特性:1.线性扩展。能够丝滑的扩容到成百上千个节点(Kafka扩容需要占用很多系统资源在节点间拷贝数据,而Plusar完全不用)2.高吞吐。每秒数百万消息3.低延迟。在大规模的消息量下依然能够保持低延迟(< 5ms)4.持久化机制。Plusar的持久化机制构建在Apache BookKeeper之上,提供了写与读之前的IO隔离5.基于