最近项目中使用了netty服务,空余时间差了下dubbo中是如何使用netty做底层服务的,找了相关资料记录一下: 众所周知,国内知名框架 Dubbo 底层使用的是 Netty 作为网络通信,那么内部到底是如何使用的呢? 1. dubbo 的 Consumer 消费者如何使用 Netty --dem ...
分类:
Web程序 时间:
2020-04-25 19:12:57
阅读次数:
67
一、Kafka介绍 Kafka是一个开源的分布式消息引擎/消息中间件,同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息,同时并基于消息功能添加了Kafka Connect、Kafka Streams以支持连接其他系统的数据(Elasticsearch、Hadoop等 ...
分类:
系统相关 时间:
2020-04-23 12:02:24
阅读次数:
86
1】Receiver是使用高层次的consumer Api来实现的。 receiver 接收的消息都是存储在spark Executor中的,然后spark启动jobq去处理那些消息 然而,默认情况下,这种方式会因为底层的失败丢失数据。 如果要启用高可靠机制,让数据零丢失,就必须启用spark st ...
分类:
其他好文 时间:
2020-04-20 11:59:44
阅读次数:
64
网关的概念 1、什么是路由网关 网关是系统的唯一对外的入口,介于客户端和服务器端之间的中间层,处理非业务功能 提供路由请求、鉴权、监控、缓存、限流等功能。它将"1对N"问题转换成了"1对1”问题。 通过服务路由的功能,可以在对外提供服务时,只暴露 网关中配置的调用地址,而调用方就不需要了解后端具体的 ...
分类:
编程语言 时间:
2020-04-19 09:22:36
阅读次数:
96
一、概述1.1、简介Kafka最初是由LinkedIn公司开发,是一个分布式、分区的、多副本的、多订阅者,基于zookeeper协调的分布式日志系统。ApacheKafka也是一个开源消息系统,由Scala写成;Kafka是一个分布式消息队列。Kafka对消息保存是根据Topic进行归类,发送消息者称为Producer,消息接受者称为Consumer,此外kafka集群有多个kafka实例组成,每
分类:
其他好文 时间:
2020-04-17 09:28:47
阅读次数:
71
一、Spring Cloud简介 Spring Cloud是一个分布式的整体解决方案。Spring Cloud 为开发者提供了在分布式系统 (配置管理,服务发现,熔断,路由,微代理,控制总线,一次性token,全局琐,leader选举, 分布式session,集群状态)中快速构建的工具,使用Spri ...
分类:
编程语言 时间:
2020-04-16 22:12:30
阅读次数:
92
什么是Dubbo? Dubbo是一个RPC远程调用 分布式服务治理 框架. 是Alibaba开源的分布式服务框架 Dubbo能做什么? 负载均衡、容错、降级、路由规则、自动注册服务。 节点角色说明: Provider: 暴露服务的服务提供方。 Consumer: 调用远程服务的服务消费方。 Regi ...
分类:
其他好文 时间:
2020-04-16 18:09:47
阅读次数:
101
构建comsumer 新建config和controller、service的包。这里就来模拟正式的调用了。 定义接口类 接口的实现类。目标就是要在接口内实现provider里面的测试方法。 创建ComsumerController service层加上注解 远程调用 spring 默认给我们提供好 ...
分类:
其他好文 时间:
2020-04-15 00:39:28
阅读次数:
62
一、搭建项目 1、创建feign-consumer模块 pom <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org ...
分类:
编程语言 时间:
2020-04-12 16:23:18
阅读次数:
74