-
如何在springcloud分布式系统中实现分布式锁？
一、简介 一般来说，对数据进行加锁时，程序先通过acquire获取锁来对数据进行排他访问，然后对数据进行一些列的操作，最后需要释放锁。Redis 本身用 watch命令进行了加锁，这个锁是乐观锁。使用 watch命令对于频繁访问的键会引起性能的问题。 二、redis命令介绍 SETNX命令（SET if Not eXists） 当且仅当 key 不存在，将 key 的值设为 value ，并返回1…- 5
- 0
-
SpringBoot+Redis分布式锁：模拟抢单
**本篇内容主要讲解的是redis分布式锁，这个在各大厂面试几乎都是必备的，下面结合模拟抢单的场景来使用她；本篇不涉及到的redis环境搭建，快速搭建个人测试环境，这里建议使用docker；本篇内容节点如下： ** jedis的nx生成锁 如何删除锁 模拟抢单动作(10w个人开抢) jedis的nx生成锁 对于java中想操作redis，好的方式是使用jedis，首先pom中引入依赖： 1<…- 2
- 0
-
基于redis(lua)和zookeeper分布式锁(秒杀)实现,分布式接口幂等,分布式速率限制器,分布式ID生成器.
最近的项目中遇到分布式幂等问题，在本文中，我将用一个简单demo，简单阐述下使用分布式锁解决幂等问题以及分布式环境下秒杀扣库存并发问题的解决基本思路。 推荐视频链接 Java 微服务实践视频教程 - Spring Boot Java 微服务实践 视频教程- Spring Cloud redis高可用视频 分布式电商商城视频教程 kubernets+docer jvm 秒杀项目实战 Linux sh…- 24
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day02 后台服务的搭建&Swagger接口
前言： 前面我们已经搭建了一个基础模块 今天我们就来做进一步的开发 今日任务： 文章目录 HRM的仓库搭建(码云) 系统管理需求分析 涉及模块 MybatisPlus MybatisPlus与项目的集成 后台服务的搭建 后台服务集成网关 接口文档Swagger 问题 HRM的仓库搭建(码云) 在码云上搭建一个项目的一个仓库 不知道怎么操作的请参考这篇文章 IDEA中项目同步到码云 搭建好后我们需要…- 7
- 0
-
SpringCloud微服务知识整理六：声明式服务调用 Spring Cloud Feign
什么是Spring Cloud Feign Spring Cloud Feign 是基于 Netflix Feign 实现的，整合了 Spring Cloud Ribbon 和 Spring Cloud Hystrix，除了提供这两者的强大功能之外，还提供了一种声明式的 Web 服务客户端定义方式。 一、快速入门 1、创建一个 Spring Boot 基础工程，取名为 feign-consumer…- 0
- 0
-
SpringCloud微服务知识整理一：基础知识
一.什么是微服务 将一个原本独立的单体系统拆分成多个微服务，各自独立运行，通过 HTTP的RESTful API 进行通信协作，属于架构范畴的一种设计风格。 微服务优点 1.它们往往比传统的应用程序更有效地利用计算资源。这是因为它们通过扩展组件来处理功能瓶颈问题。只需要为额外的组件部署计算资源，而不需要部署一个完整的应用程序的全新迭代。最终的结果是有更多的资源可以提供给其它任务。 2.它们更快且更…- 6
- 0
-
微服务架构核心技术三
康威法则和启示 Melvin Conway于1967提出康威法则: 博客地址: http://melconway.com/Home/Conways_Law.html Any organization that designs a system (defined broadly) will produce a design whose structure is a copy of the organ…- 1
- 0
-
微服务架构核心技术十二
微服务路由发现体系 图示: netflix路由发现体系中两个非常重要的支撑服务是Eureka服务注册中心，和zuul网关.内部服务的发现通过Eureka来注册发现，聚合服务通过注册服务中心做服务发现，拉取路由表，缓存在客户端。网关层会同步服务注册中心的路由表，进行调用聚合服务- 10
- 0
-
Spring Cloud构建微服务架构：服务消费（Feign）【Dalston版】
Spring Cloud Feign Spring Cloud Feign是一套基于Netflix Feign实现的声明式服务调用客户端。它使得编写Web服务客户端变得更加简单。我们只需要通过创建接口并用注解来配置它既可完成对Web服务接口的绑定。它具备可插拔的注解支持，包括Feign注解、JAX-RS注解。它也支持可插拔的编码器和解码器。Spring Cloud Feign还扩展了对Spring…- 5
- 0
-
Spring Cloud构建微服务架构：分布式服务跟踪（抽样收集）【Dalston版】
通过 Trace ID和 Span ID已经实现了对分布式系统中的请求跟踪，而这些记录的跟踪信息最终会被分析系统收集起来，并用来实现对分布式系统的监控和分析功能，比如：预警延迟过长的请求链路、查询请求链路的调用明细等。此时，我们在对接分析系统时就会碰到一个问题：分析系统在收集跟踪信息的时候，需要收集多少量的跟踪信息才合适呢？ 理论上来说，我们收集的跟踪信息越多就可以更好的反映出系统的实际运行情况，…- 42
- 0
-
ASP.NET Core微服务之基于Steeltoe使用Zipkin实现分布式追踪
一、关于Spring Cloud Sleuth与Zipkin 在 SpringCloud 之中提供的 Sleuth 技术可以实现微服务的调用跟踪，也就是说它可以自动的形成一个调用连接线，通过这个连接线使得开发者可以轻松的找到所有微服务间关系，同时也可以获取微服务所耗费的时间， 这样就可以进行微服务调用状态的监控以及相应的数据分析。 Zipkin是一个分布式追踪系统，它有助于收集解决微服务架构中…- 1
- 0
-
Netty游戏服务器实战开发(1):Netty 的自带解码器
LineBasedFrameDecoder LineBasedFrameDecoder是回车换行解码器，如果用户发送的消息以回车换行符作为消息结束的标识，则可以直接使用Netty的LineBasedFrameDecoder对消息进行解码，只需要在初始化Netty服务端或者客户端时将LineBasedFrameDecoder正确的添加到ChannelPipeline中即可，不需要自己重新实现一套换行…- 10
- 0
-
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)—->第2节: FastThreadLocal的set方法…
Netty源码分析第8章(高性能工具类FastThreadLocal和Recycler)---->第2节: FastThreadLocal的set方法 Netty源码分析第八章: 高性能工具类FastThreadLocal和Recycler 第二节: FastThreadLocal的set方法 上一小节我们学习了FastThreadLocal的创建和get方法的实现逻辑, 这一小…- 0
- 0
-
Netty源码分析第4章(pipeline)—->第6节: 传播异常事件
Netty源码分析第四章: pipeline 第6节: 传播异常事件 讲完了inbound事件和outbound事件的传输流程, 这一小节剖析异常事件的传输流程 首先我们看一个最最简单的异常处理的场景: 1@Override 2public void channelRead(ChannelHandlerContext ctx, Object msg) throws Except…- 18
- 0
-
Netty源码分析第1章(Netty启动流程)—->第1节: 服务端初始化
Netty源码分析第一章: Server启动流程 概述: 本章主要讲解server启动的关键步骤, 读者只需要了解server启动的大概逻辑, 知道关键的步骤在哪个类执行即可, 并不需要了解每一步的运作机制, 之后会对每个模块进行深度分析 第一节:服务端初始化 首先看下在我们用户代码中netty的使用最简单的一个demo: 1//创建boss和worker线程(1…- 12
- 0
-
Netty In Action中文版 – 第十章：单元测试代码
Netty In Action中文版 - 第十章：单元测试代码 本章介绍 单元测试 EmbeddedChannel 学会了使用一个或多个ChannelHandler处理接收/发送数据消息，但是如何测试它们呢？Netty提供了2个额外的类使得测试ChannelHandler变得很容易，本章讲解如何测试Netty程序。测试使用JUnit4，如果不会用可以慢慢了解。JUnit4很简单，但是功能很强大。本…- 9
- 0
-
Mina、Netty、Twisted一起学（六）：session
开发过Web应用的同学应该都会使用session。由于HTTP协议本身是无状态的，所以一个客户端多次访问这个web应用的多个页面，服务器无法判断多次访问的客户端是否是同一个客户端。有了session就可以设置一些和客户端相关的属性，用于保持这种连接状态。例如用户登录系统后，设置session标记这个客户端已登录，那么访问别的页面时就不用再次登录了。 不过本文的内容不是Web应用的session，而…- 7
- 0
-
Java NIO框架Netty教程（二） – 白话概念
"Hello World" 的代码固然简单，不过其中的几个重要概念（类）和 Netty的工作原理还是需要简单明确一下，至少知道其是负责什。方便自己以后更灵活的使用和扩展。 声明，笔者一介码农，不会那么多专业的词汇和缩写，只能以最简单苍白的话来形容个人的感受和体会。如果您觉得这太不专业，笔者首先只能抱歉。然后，笔者曾转过《 Netty代码分析》，您可参考。 ChannelEv…- 7
- 0
-
Java NIO框架Netty教程(十四)-Netty中OIO模型(对比NIO)
OneCoder这个周末搬家，并且新家目前还没有网络，本周的翻译的任务尚未完成，下周一起补上，先上一篇OIO和NIO对比的小研究。 Netty中不光支持了Java中NIO模型，同时也提供了对OIO模型的支持。（New IO vs Old IO）。 首先，在Netty中，切换OIO和NIO两种模式是非常方便的，只需要初始化不同的Channel工程即可。 1ServerBootstrap bootst…- 22
- 0
-
一个轻量级分布式RPC框架–NettyRpc
1、背景 最近在搜索Netty和Zookeeper方面的文章时，看到了这篇文章《轻量级分布式 RPC 框架》，作者用Zookeeper、Netty和Spring写了一个轻量级的分布式RPC框架。花了一些时间看了下他的代码，写的干净简单，写的RPC框架可以算是一个简易版的dubbo。这个RPC框架虽小，但是麻雀虽小，五脏俱全，有兴趣的可以学习一下。 本人在这个简易版的RPC上添加了如下特性： * 服…- 16
- 0
-
kafka原理系列之（一）消息存储和offset提交机制
kafka之消息存储和offset提交机制 Kafka具有存储功能，默认保存数据时间为7天或者大小1G，也就是说kafka broker上的数据超7天或者1G， 就会被清理掉。这些数据存放在broker服务器上，以log文件的形式存在。 kafka的安装目录下面的/conf/server.propertites文件中中设置： 1### 日志保存时间 (hours|minutes)，默认为7天（16…- 14
- 0
-
RabbitMQ VS Apache Kafka （四）—— 应用场景如何选择？
架构对比 RabbitMQ是一个通用的消息代理，通过包括点对点、请求/响应及发布订阅在内的多种消息通信模式。其采用的是一种智能代理/傻瓜消费的模式，侧重消息的持续投递与处理，并通过代理本身来维护消费者自身状态。RabbitMQ是一个设计成熟的消息代理中间件，支持包括Java, node.js, .NET, Ruby, PHP等在内的多种客户端，并且提供有多种插件来扩展自身功能。 RabbitMQ支…- 7
- 0
-
如何管理Spark Streaming消费Kafka的偏移量（二）
上篇文章，讨论了在spark streaming中管理消费kafka的偏移量的方式，本篇就接着聊聊上次说升级失败的案例。 事情发生一个月前，由于当时我们想提高spark streaming程序的并行处理性能，于是需要增加kafka分区个数，，这里需要说下，在新版本spark streaming和kafka的集成中，按照官网的建议 spark streaming的executors的数量要和kafk…- 21
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×