7 sharedCode

尚未进行身份认证

我要认证

拥有6年开发经验,目前担任某公司的架构师岗位。

等级
TA的排名 1w+

如何在MQ中实现支持任意延迟的消息?

https://www.cnblogs.com/hzmark/p/mq-delay-msg.html

2020-06-02 17:38:01

多线程篇-TransmittableThreadLocal解决池化复用线程的传值问题

文章首发在我的个人博客网站,本篇文章的地址在下面,欢迎!多线程篇-TransmittableThreadLocal解决池化复用线程的传值问题

2020-04-24 11:52:33

多线程篇-父子线程的上下文传递

后续文章首发在个人博客,欢迎移驾我的个人博客浏览该文章,地址在下方多线程篇-父子线程的上下文传递

2020-04-23 12:26:49

阿里java开发手册-泰山版发布

欢迎移驾我的个人博客网站: https://shared-code.com《Java开发手册》始于阿里内部规约,在全球Java开发者共同努力下,已成为业界普遍遵循的开发规范。手册涵盖编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程规约、设计规约七大维度。此次泰山版发布,将带来三大亮点:新增5条日期时间规约;新增2条表别名sql规约;新增统一错误码规约。下载方式:关注公众...

2020-04-22 11:57:46

RocketMQ系列之Consumer启动(五)

官方示例本文的示例是通过push的方式创建的消费者,push和pull的消费者在启动的流程上源码是差不多的public static void main(String[] args) throws InterruptedException, MQClientException { // 创建一个消费者对象 DefaultMQPushConsumer consumer =...

2020-03-20 15:45:29

RocketMq系列之Producer顺序消息发送源码分析(四)

有序消息消息有序指的是可以按照消息的发送顺序来消费。RocketMQ可以严格的保证消息有序。但这个顺序,不是全局顺序,只是分区(queue)顺序。顺序消息生产者public static void main(String[] args) throws UnsupportedEncodingException { try { DefaultMQProd...

2020-01-06 12:09:20

RocketMq系列之Producer顺序消息发送源码分析(四)

有序消息消息有序指的是可以按照消息的发送顺序来消费。RocketMQ可以严格的保证消息有序。但这个顺序,不是全局顺序,只是分区(queue)顺序。顺序消息生产者public static void main(String[] args) throws UnsupportedEncodingException { try { DefaultMQProd...

2019-10-10 14:18:50

RocketMq系列之Producer普通消息发送(三)

普通消息发送下面是普通消息发送的示例public static void main(String[] args) throws MQClientException, InterruptedException { DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name"...

2019-10-08 17:47:32

RocketMq系列之topic路由信息更新(二)

前言本文的主要是为了介绍,在生产者或者消费者启动的时候,需要实例化MqClientInstance,作为负责和borker通信的实例, 在这个里面初始化了很多定时任务,心跳,nameServer地址更新, topic路由信息更新源码入口org.apache.rocketmq.client.impl.factory.MQClientInstancepublic void start() th...

2019-09-29 21:35:41

RocketMq系列之Producer启动源码分析(一)

前言笔者写的rokcetMq的源码分析,都是基于4.5.1版本。源码入口下面是一个很简单的服务端启动的两行源码MQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");producer.start();启动源码的逻辑主要集中在start方法里面@Override public...

2019-09-21 11:53:55

RocketMQ4.0.0单机版配置(试水篇)

前言时隔一年多,博客停更了一年多,这一年多也一直忙着做业务,天天跟产品,测试及其他部门扯皮,每天奔波于各个部门之间,处理一些团队上的事情, 回首再看看,忽然发现技术其实拉下了很多,希望后续可以继续坚持吧。一、安装与配置下载官网:http://rocketmq.apache.org/如:rocketmq-all-4.0.0-incubating-bin-release.zip解压文件之后...

2019-09-20 16:33:35

spingboot整合sharding-sphere4.0.0.RC2分库分表

pom文件<dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>4.0.0-RC2</versio...

2019-09-19 14:37:34

sleuth+zipkin+kafka+logstash链路追踪二次开发方案

系统架构方案方案一架构说明:1.应用接入zipkin客户端,将span的信息直接推送给kafka2.zipkin-server定kafka中订阅主体为sleuth的消息,将span中的信息推送到elasticsearch中3.zipkin-ui项目负责从elasticsearch读取信息,分析信息,呈现图标给用户。方案二架构说明:1.接入链路追踪的客户端,仅需对本地日志输出进行...

2019-07-01 14:31:27

ThreadLocalRandom随机数源码分析

ThreadLocalRandom介绍ThreadLocalRandom是JDK1.7以后提供出来的一个随机数生成工具类,性能比传统的Math.random()更高。性能比较ThreadLocalRandom和Math.random()的性能比较,测试步骤如下:public class Test { public static void main(String[] args) t...

2019-05-08 18:47:22

一起了解一下微服务

版权声明:尊重博主原创文章,转载请注明出处 https://blog.csdn.net/eson_15/article/details/83651732 通常而言,微服务架构是一种架构模式或者说一种架构风格,它提倡将单一应用程序划分成一组小的服务,每个服务运行在其独立的进程中,服务之间互相协调、互相配合,为用户提供最终的价值。服务之间采用轻量级的通信机...

2018-11-04 15:07:48

dubbo系列之内核SPI-Protocol扩展类生成(九)

前文回顾上一篇文章我们讲到,扩展实现类的类上如果写上了@Adaptive注解,则可以直接取得扩展实现类对象,其他的需要通过字节码生成技术来生成对象,接着上文的代码讲解,调用createAdaptiveExtensionClass方法生成扩展实现类对象createAdaptiveExtensionClassprivate Class<?> createAdaptiveExtensi...

2018-11-01 11:12:28

dubbo系列之内核SPI-资源解析&依赖注入(八)

前文回顾上文中,我们了解了dubbo的SPI机制,针对Protocol的SPI实现讲解了一半,讲到了Protocol生成好了ExtensionLoader以及其内部的ExtensionFactory , 本文继续讲解接下来的代码,建议没看过上一篇文章的朋友可以先去看下一,直接看本文会比较懵逼 。dubbo系列之内核SPI拓展机制初识(七)###源码入口com.alibaba.dubbo.c...

2018-10-26 10:12:35

dubbo系列之内核SPI拓展机制初识(七)

前言dubbo为了适应不同的注册中心,底层通讯协议等功能的扩展,采用SPI的思想,即Service Provider Interface , 也就是我们定义了服务接口标砖,让服务商去实现。 jdk通过ServiceLoader类实现了SPI机制的服务查找功能,有兴趣的可以去网上搜一下jdk的SPI思想, , 接下来我们会讲解一下dubbo是如何实现SPI机制,SPI机制一般来说,会提供一个接...

2018-10-24 10:22:32

dubbo系列之ServiceBean介绍(六)

前言前面几篇文章中,我们了解了spring是如何解析@Service,@Reference注解的,今天主要讲的是服务暴露者的一个非常重要的类,ServiceBean , 每个暴露出去的服务都会生成一个ServiceBean.ServiceBean该类的继承实现关系如下public class ServiceBean<T> extends ServiceConfig<T&...

2018-10-22 10:11:51

dubbo系列之@Reference注解解析原理(五)

前言上文中我们讲解了@Service注解的解析原理,了解到Dubbo默认支持两种方式进行解析,一种是通过springboot 自动配置来做的,另外一种是通过DubboComponentScan 注解来解析的,本文继续也是以DubboComponentScan 的方式来讲解的。源码入口com.alibaba.dubbo.config.spring.context.annotation.D...

2018-10-18 10:19:18

查看更多

CSDN身份
  • 博客专家
勋章 我的勋章
  • 阅读者勋章Lv1
    阅读者勋章Lv1
    授予在CSDN APP累计阅读博文达到3天的你,是你的坚持与努力,使你超越了昨天的自己。
  • 专栏达人
    专栏达人
    授予成功创建个人博客专栏的用户。专栏中添加五篇以上博文即可点亮!撰写博客专栏浓缩技术精华,专栏达人就是你!
  • 持之以恒
    持之以恒
    授予每个自然月内发布4篇或4篇以上原创或翻译IT博文的用户。不积跬步无以至千里,不积小流无以成江海,程序人生的精彩需要坚持不懈地积累!
  • 1024勋章
    1024勋章
    #1024程序员节#活动勋章,当日发布原创博客即可获得
  • 勤写标兵Lv1
    勤写标兵Lv1
    授予每个自然周发布1篇到3篇原创IT博文的用户。本勋章将于次周周三上午根据用户上周的博文发布情况由系统自动颁发。