标签:consumer

Spring

Spring整合ActiveMQ项目实战

10

hellas 发布于 2019-05-21

引言 Apache ActiveMQ是Apache软件基金会所研发的开放源代码消息中间件,说白了就是个服务器,主要用来存放请求消息的 原理 这篇博客图文并茂,通俗易懂ActiveMQ作用总结 笔者将其精炼了一下,主要有4大应用场景:异步处理,应用解耦,流量削锋,消息通讯 其核心思...

阅读(9)评论(0)赞 (0)

Java

Dubbo线程模型和调度策略

3

songhua.gao 发布于 2019-05-21

首先服务消费者通过代理对象 Proxy 发起远程调用,接着通过网络客户端 Client 将编码后的请求发送给服务提供方的网络层上,也就是 Server。Server 在收到请求后,首先要做的事情是对数据包进行解码。然后将解码后的请求发送至分发器 Dispatcher,再由分发器将...

阅读(10)评论(0)赞 (0)

Java

17 个方面,综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列

1

zhuangli 发布于 2019-05-21

 一、资料文档 二、开发语言 三、支持的协议 四、消息存储 五、消息事务 六、负载均衡 七、集群方式 八、管理界面 九、可用性 十、消息重复 十一、吞吐量TPS 十二、订阅形式和消息分发 十三、顺序消息 十四、消息确认 十五、消息回溯 十六、消息重试 十七、并发度 本文...

阅读(8)评论(0)赞 (0)

编程技术

Kafka两级调度实现分布式协调微服务任务分配Golang版

8

wenming.gapo 发布于 2019-05-21

背景 基于Kafka消息队列的两级协调调度架构 Kafka内部为了协调内部的consumer和kafka connector的工作实现了一个复制协议, 主要工作分为两个步骤: 通过worker(consumer或connect)获取自身的topic offset等元数据信息,交给...

阅读(11)评论(0)赞 (0)

Java

Apache Dubbo 晋升为 Apache 基金会顶级项目

1

zhuangli 发布于 2019-05-21

Apache 基金会发布 公告 ,宣布 Apache Dubbo 从孵化器毕业,成为 Apache 基金会顶级项目。 Apache Dubbo 是阿里巴巴公司开源的一个高性能优秀的服务框架,使得应用可通过高性能的 RPC 实现服务的输出和输入功能,可以和Spring框架无缝集成。...

阅读(9)评论(0)赞 (0)

Java

Rxjava2.x源码解析(二): 线程切换

3

小丁 发布于 2019-05-21

上一篇文章 Rxjava2.x源码解析(一): 订阅流程 中我们讲了 RxJava2 的订阅部分的源码。但 RxJava2 最强大的部分其实是在异步。默认情况下,下游接收事件所在的线程和上游发送事件所在的线程是同一个线程。接下来我们在上一篇文章的示例代码中加入线程切换相关代码: ...

阅读(7)评论(0)赞 (0)

Java

Rxjava2.x源码解析(一): 订阅流程

3

Harries 发布于 2019-05-21

现在网上已经有大量的源码分析文章,各种技术的都有。但我觉得很多文章对初学者并不友好,让人读起来云里雾里的,比源码还源码。究其原因,是根本没有从学习者的角度去分析。在自己完成了源码阅读之后,却忘记了自己是如何一步步提出问题,进而走到这里的。 所以,我想在本篇及以后的文章中,花更多的...

阅读(9)评论(0)赞 (0)

Java

Dubbo消费者consumer捕捉服务提供者provider抛出的自定义异常

songhua.gao 发布于 2019-05-20

在一个公共包里定义一个异常类,继承自RuntimeException。 public class BusinessException extends RuntimeException { /** * 异常code */ private String code; public Bu...

阅读(13)评论(0)赞 (0)

Java

用最低的成本,提高你的代码稳壮性

2

yanxinchi 发布于 2019-05-20

配置参数启动时校验 如果配置文件没有相关的配置,那么** 启动时 **就会出现以下异常: Description: Binding to target com.toby.provide.ApplicationProperties@31da6b2e failed: Property...

阅读(14)评论(0)赞 (0)

Java

Dubbo与Spring Cloud

13

邓龙华 发布于 2019-05-19

目录 1.Sping Cloud 2.Dubbo 1.Spring Cloud Spring Cloud,从命名我们就可以知道,它是Spring Source的产物,Spring社区的强大背书可以说是Java企业界最有影响力的组织了,除了Spring Source之外,还有Piv...

阅读(17)评论(0)赞 (0)

Java

Spring Cloud Gateway-ServerWebExchange核心方法与请求或者响应内容的修改

Harries 发布于 2019-05-18

本文编写的时候使用的 Spring Cloud Gateway 版本为当时最新的版本 Greenwich.SR1 。 我们在使用 Spring Cloud Gateway 的时候,注意到过滤器(包括 GatewayFilter 、 GlobalFilter 和过滤器链 Gatew...

阅读(17)评论(0)赞 (0)

Java

说自己熟悉 Spring Cloud 这些面试题你会吗

9

zhuangli 发布于 2019-05-18

点击上面  蓝色字体 关注我们 技术  /  架构  /  职场  /  面试   /  内推 问题一: 什么是Spring Cloud? Spring cloud流应用程序启动器...

阅读(19)评论(0)赞 (0)

Java

Java 8 的一些新特性

xiaoli.wang 发布于 2019-05-17

java.util.function.Predicate @FunctionalInterface public interface Predicate<T> { // 函数式接口,布尔返回值 boolean test(T t); default Predicate&...

阅读(17)评论(0)赞 (0)

Java

RPC在Java中的实现

hanze 发布于 2019-05-16

RPC是一种远程过程调用, 它是一种通过网络从远程计算机程序上请求服务, 而不需要了解底层网络技术的协议 RPC可以把远程服务像本地服务一样调用, 以 Java 中为例, 客户端与服务端一般共用一个核心包, 核心包中包含了需要调用服务的接口 在服务端实现这些接口, 客户端通过 S...

阅读(20)评论(0)赞 (0)

Spring

SpringCloud微服务治理二(Robbin,Hystix,Feign)

11

puefu.he 发布于 2019-05-15

在刚才的案例中,我们启动了一个user-service,然后通过DiscoveryClient来获取服务实例信息,然后获取ip和端口来访问。 但是实际环境中,我们往往会开启很多个user-service的集群。此时我们获取的服务列表中就会有多个,到底该访问哪一个呢? 一般这种情况...

阅读(29)评论(0)赞 (0)

Java

借助混沌工程工具 ChaosBlade 构建高可用的分布式系统 原 荐

1

hellas 发布于 2019-05-14

在分布式架构环境下,服务间的依赖日益复杂,可能没有人能说清单个故障对整个系统的影响,构建一个高可用的分布式系统面临着很大挑战。在可控范围或环境下,使用 ChaosBlade 工具,对系统注入各种故障,持续提升分布式系统的容错和弹性能力,以构建高可用的分布式系统。 ChaosBla...

阅读(26)评论(0)赞 (0)