标签:consumer

Java

RxJava(十二):RxBinding

1

dulong 发布于 2020-01-19

博客主页 1. RxBinding 简介 1.1 RxBinding 介绍 RxBinding 是 Jake Wharton 大神写的框架,它的 API 能够把 Android 平台和兼容包内的 UI 控件变为 Observable 对象,这样就可以把 UI 控件的事件当作 Rx...

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

Java

RxJava(十一): 并行编程

xiaoli.he 发布于 2020-01-19

博客主页 1. RxJava 并行操作 被观察者( Observable/Flowable/Single/Completable/May )发射的数据流可以经历各种线程切换,但是数据流的各个元素之间不会产生并行执行的效果。井行不是并发,也不是同步,更不是异步。 并发( concu...

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

Java

SpringBoot探索03 – 条件注解

darida 发布于 2020-01-18

SpringBoot中提供了一系列的条件注解( @ Conditional )来实现对 @ Bean 和 @ Configuration 等实例的创建进行约束。这些注解包括: Class Conditions ,类条件约束 Bean Conditions ,Bean条件约束 Pr...

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

Spring

Spring-cloud微服务实战【二】:eureka注册中心(上)

38

刘莉莉 发布于 2020-01-18

前言 本系列教程旨在为大家演示如何一步一步构建一整套微服务系统,至于其中的数据库用什么,订单ID如何保持唯一,分布式相关问题等等不在我们讨论范围内,本教程为了方便大家后续下载代码运行测试,不依赖任何其他诸如缓存、数据库之类的资源,此类操作我们在项目中使用代码的方式来模拟。 我们的...

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

Java

深入理解RPC之Dubbo的应用及原理解析

66

Harries 发布于 2020-01-17

分布式系统是若干独立计算机的集合,这些计算机对于用户来说就像单个相关系统。 分布式系统(distributed system)是建立在网络之上的软件系统。 为什么会出现分布式系统 随着互联网的发展,网站的应用规模不断扩大,常规的垂直应用架构已经无法应对,分布式服务架构以及流动计算...

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

Java

聊聊artemis ClientConsumer的handleRegularMessage

xirruiqiang 发布于 2020-01-17

序 本文主要研究一下artemis ClientConsumer的handleRegularMessage handleRegularMessage activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/apa...

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

Java

Java 基础(二)| 使用 lambad 表达式的正确姿势

3

尖兵 发布于 2020-01-17

前言 为跳槽面试做准备,今天开始进入 Java 基础的复习。希望基础不好的同学看完这篇文章,能掌握 lambda 表达式,而基础好的同学权当复习,希望看完这篇文章能够起一点你的青涩记忆。 一、什么是 lambda 表达式 Java8 是我们使用最广泛的稳定 Java 版本,lam...

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

Java

RxJava(十):Disposable 和 Transformer的使用

yanxinchi 发布于 2020-01-17

博客主页 1. Disposable 在 RxJav 1.x 中, Subscription 的接口可以用来取消订阅。 public interface Subscription { /** * Stops the receipt of notifications on the ...

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

Java

RxJava(九):背压

songhua.gao 发布于 2020-01-17

博客主页 1. 背压 在 RxJava 中, 会遇到被观察者发送消息太快以至于它的操作符或者订阅者不能及时处理相关的消息,这就是典型的背压( Back Pressure )场景。 在 RxJava 官方的维基百科中关于 Back Pressure 是这样描述的: In React...

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

Java

RxJava(八):合并操作符和连接操作符

9

darida 发布于 2020-01-17

博客主页 RxJava 的合并操作符主要包括如下几个: startWith :在数据序列的开头增加一项数据 merge :将多个 Observable 合并为一个 mergeDelayError :合并多个 Observable,让没有错误的 Observable 都完成后再发射...

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

Java

netty RPC的简易DEMO

1

wenming.gapo 发布于 2020-01-16

这个是rpc远程调用的简单demo:Consumer通过rpc远程调用Provider的服务方法sayHelloWorld(String msg),然后Provider返回""Hello World"给Consumer。 这里采用netty来实现远程...

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

Java

学习java8这篇文章就够了

1

xiaoli.he 发布于 2020-01-16

本文分3部分 java8-基础 主要讲述java8的一些基础概念及用法。包括:Optional类,Lambda表达式,Stream接口。 java8-进阶 主要讲述java8的一些进阶用法。包括:Function接口,自定义Stream接口。 java8-实践 主要讲述java8...

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

Java

RxJava(六):过滤操作符

11

Harries 发布于 2020-01-16

博客主页 RxJava 的过滤操作符主要包括以下几种: filter:过滤数据 takeLast:只发射最后的 N 项数据 last :只发射最后一项数据 lastOrDefault:只发射最后一项数据,如果 Observable 空,就发射默认值。 takeLastBuffer...

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

Java

聊聊artemis的SessionConsumerFlowCreditMessage

puefu.he 发布于 2020-01-16

序 本文主要研究一下artemis的SessionConsumerFlowCreditMessage SessionConsumerFlowCreditMessage activemq-artemis-2.11.0/artemis-core-client/src/main/jav...

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

Java

Rxjava(七):条件操作符和布尔操作符

9

小丁 发布于 2020-01-16

博客主页 RxJava 的条件操作符主要包括以下几个: amb :给定多个 Observable ,只让第一个发射数据的 Observable 发射全部数据 defaultlfEmpty :发射来自原始 Observable 的数据,如果原始 Observable 没有发射数据,...

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

Java

大数据方向学习面试知识图谱

5

yeseng 发布于 2020-01-15

正所谓,无招胜有招。 愿读到这篇文章的技术人早日明白并且脱离技术本身,早登彼岸。 一切技术最终只 是雕虫小 技 。 大纲 本系列主题是大数据开发面试指南,旨在为大家提供一个大数据学习的基本路线,完善数据开发的技术栈,以及我们面试一个大数据开发岗位的时候,哪些东西是重点考察的,这些...

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

Java

聊聊artemis的SessionProducerCreditsMessage

yanxinchi 发布于 2020-01-15

序 本文主要研究一下artemis的SessionProducerCreditsMessage SessionProducerCreditsMessage activemq-artemis-2.11.0/artemis-core-client/src/main/java/org/...

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