-
docker微服务部署之：三，搭建Zuul微服务项目
docker微服务部署之：二、搭建文章微服务项目 一、新增demo_eureka模块,并编写代码 右键demo_parent->new->Module->Maven,选择Module SK为jdk8->ArtifactId:demo_zuul 1.修改pom.xml文件 1<?xml version="1.0" encoding="UTF…- 4
- 0
-
SpringCloud微服务知识整理三：服务治理 Spring Cloud Eureka
什么是Spring Cloud Eureka Spring Cloud Eureka是Spring Cloud Netflix 微服务套件中的一部分，它基于Netflix Eureka做了二次封装，主要负责完成微服务架构中的服务治理功能。Spring Cloud 通过为Eureka增加了Spring Boot风格的自动化配置，我们只需通过引入依赖和注解配置就能让Spring Boot构建的微服务应…- 20
- 0
-
微服务架构核心技术六
阿里巴巴中台战略 马云在到芬兰supercell公司参观回国后,阿里巴巴在2015年底正式宣布启动中台战略.实现了服务重用和业务沉淀.强化业务中台和技术中台，对上层应用支撑越强，赋能业务持续创新，快速响应市场需求 推荐书籍: 企业IT架构转型之道 现代互联网技术体系可以大致分为下面四个层次: IaaS基础设施即服务->Paas平台即服务->核心业务层->PC主站/APP/h5等应…- 0
- 0
-
ASP.NET Core微服务之基于Apollo实现统一配置中心
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、关于统一配置中心与Apollo 在微服务架构环境中，项目中配置文件比较繁杂，而且不同环境的不同配置修改相对频繁，每次发布都需要对应修改配置，如果配置出现错误，需要重新打包发布，时间成本较高，因此需要做统一的配置中心，能做到自动更新配置文件信息，解决以上问题。 Apollo（阿波罗）是携程框架部门研发的配置管理平台，能够集中化管理应用…- 5
- 0
-
ASP.NET Core微服务之基于Ocelot实现API网关服务（2）
Tip: 此篇已加入.NET Core微服务基础系列文章索引 一、负载均衡与请求缓存 1.1 负载均衡 为了验证负载均衡，这里我们配置了两个Consul Client节点，其中ClientService分别部署于这两个节点内（192.168.80.70与192.168.80.71）。 为了更好的展示API Repsonse来自哪个节点，我们更改一下返回值： 1 [Route("api/[…- 8
- 0
-
Spring Cloud构建微服务架构：消息驱动的微服务（入门）【Dalston版】
之前在写Spring Boot基础教程的时候写过一篇《Spring Boot中使用RabbitMQ》。在该文中，我们通过简单的配置和注解就能实现向RabbitMQ中生产和消费消息。实际上我们使用的对RabbitMQ的starter就是通过Spring Cloud Stream中对RabbitMQ的支持来实现的。下面我们就通过本文来了解一下Spring Cloud Stream。 Spring Cl…- 1
- 0
-
Spring Cloud构建微服务架构：分布式配置中心【Dalston版】
info: profile: default info: profile: dev org.springframework.cloud spring-cloud-config-server @EnableConfigServer @SpringBootApplication public class Application { public static void main(String[] ar…- 1
- 0
-
ASP.NET Core微服务之基于Consul实现服务治理（2）
Tip: 此篇已加入.NET Core微服务基础系列文章索引 上一篇发布之后，很多人点赞和评论，不胜惶恐，这一篇把上一篇没有弄到的东西补一下，也算是给各位前来询问的朋友的一些回复吧。 一、Consul服务注册之配置文件方式 1.1 重温Consul实验集群 这里我们有三个Consul Server节点，一个Consul Client节点，在Client节点上跑了两个ClientService实例，…- 3
- 0
-
Netty游戏服务器实战开发(6):Netty整合Zookeeper实现分布式服务发现与注册
1：Zookeeper基础 安装zookeeper。当然，很多时候我们会在Windows上开发，所以，我们需要在本地搭建一个zookeeper环境。方便开发过程中的测试。 首先我们去Apache上下载zookeeper。https://zookeeper.apache.org/ 下载下来后解压得到如下文件 打开conf里面的zoo_simple.cfg ,拷贝一份，重新命名为zoo.cfg修改如下…- 34
- 0
-
Netty源码分析第4章(pipeline)—->第2节: handler的添加
Netty源码分析第四章: pipeline 第二节: Handler的添加 添加handler, 我们以用户代码为例进行剖析: 1.childHandler(new ChannelInitializer<SocketChannel>() { 2 protected void initChannel(SocketChannel ch) throws Exception …- 7
- 0
-
Netty源码分析第2章(NioEventLoop)—->第6节: 执行selector操作
Netty源码分析第二章: NioEventLoop 第六节: 执行select操作 分析完了selector的创建和优化的过程, 这一小节分析select相关操作 跟到跟到NioEventLoop的run方法: 1protected void run() { for (;;) { try { switch (selectStrategy.calculateStrategy(selec…- 3
- 0
-
Netty源码分析第1章(Netty启动流程)—->第5节: 绑定端口
Netty源码分析第一章:Netty启动步骤 第五节:绑定端口 上一小节我们学习了channel注册在selector的步骤, 仅仅做了注册但并没有监听事件, 事件是如何监听的呢? 我们继续跟第一小节的最初的doBind()方法: 1private ChannelFuture doBind(final SocketAddress localAddress) { 2 //初始化并注册(1) …- 0
- 0
-
Netty In Action中文版 – 第二章：第一个Netty程序
Netty In Action中文版 - 第二章第一个Netty程序 本章介绍 获取Netty4最新版本 设置运行环境来构建和运行netty程序 创建一个基于Netty的服务器和客户端 拦截和处理异常 编写和运行Netty服务器和客户端 本章将简单介绍Netty的核心概念这个狠心概念就是学习Netty是如何拦截和处理异常对于刚开始学习netty的读者利用netty的异常拦截机制来调试程序问题很有帮…- 12
- 0
-
netty 自定义协议
netty 自定义协议 netty 是什么呢？ 相信很多人都被人问过这个问题。如果快速准确的回复这个问题呢？网络编程框架，netty可以让你快速和简单的开发出一个高性能的网络应用。netty是一个网络编程框架。那netty又有什么框框呢？主要有二个框。 框1：客户和服务的启动 一切通讯都有收与发，所有的服务端和客户端都是这样的姿势启动。具体的参数可以看文档。 服务端 1 public void b…- 3
- 0
-
Java NIO框架Netty教程(六)-Java NIO Selector模式
看到标题，您可能觉得，这跟Netty有什么关系呢？确实，如果你完全是使用Netty的，那么可能你可以完全不需要了解Selector。但是，不得不提的是，Netty底层关于NIO的实现也是基于Java的Selector的，是对Selector的封装。所以，我个人认为理解好Selector对于使用和理解Netty都是很多有帮助的。当然，如果您确实不关心这些，只想会用Netty就可以了。那么下文，您可以…- 9
- 0
-
Netty之http协议开发
Netty HTTP协议开发应用： 由于Netty的HTTP协议栈是基于Netty的NIO通信框架开发的，因此Netty的HTTP协议也是异步非阻塞的。 HTTP请求消息： HTTP请求由三部分组成，具体如下： HTTP请求行 请求行以一个方法符开头，以空格分开，后面跟着请求的URI和协议的版本，格式为：Method Request-URI HTTP-Version CRLF。 其中Method表…- 9
- 0
-
基于Dubbo框架构建分布式服务
转自：http://shiyanjun.cn/archives/1075.html 很好的文章 Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，…- 5
- 0
-
Netty websocket
Network protocols WebSocket是一种高级网络协议，旨在提高Web应用程序的性能和响应能力。 我们将通过编写示例应用程序来探索Netty对它们的支持。 在第12章中，您将学习如何使用WebSocket实现双向数据传输，方法是构建一个聊天室服务器，其中多个浏览器客户端可以实时通信。 您还将看到如何通过检测客户端是否支持它，从应用程序中的HTTP切换到WebSocket协议。 我…- 11
- 0
-
kafka原理系列之（四）ACK机制（数据可靠性和持久性保证）
1、kafka的ack机制的分类 1request.required.asks=0 2 3 当producer向leader发送数据时，可以通过request.required.acks参数来设置数据可靠性的级别： 0：这意味着producer无需等待来自broker的确认而继续发送下一批消息。这种情况下数据传输效率最高， 但是数据可靠性确是最低的。 1（默认）：这意味着producer在ISR中…- 114
- 0
-
RabbitMQ VS Apache Kafka （七）—— RabbitMQ消息路由原语与路由保证
路由保证 RabbitMQ和Kafka都提供给了持续的消息路由保证，两者都提供了最多一次和最少一次的路由保证，此外，Kafka还提供了有限应用场景下的仅一次可靠性路由保证。首先，我们看下这三种路由保证的具体含义： 最多一次：一个消息最多被路由不超过一次，消息可能丢失。 最少一次：消息永远不会丢失，但同一个消息可能会被路由到一个消费者多次。 仅一次：消息路由的理想模式，一个消息只被路由一次。 说消息…- 5
- 0
-
Kafka 中使用 Avro 序列化组件(三)：Confluent Schema Registry
1. schema 注册表 无论是使用传统的Avro API自定义序列化类和反序列化类还是使用Twitter的Bijection类库实现Avro的序列化与反序列化，这两种方法都有一个缺点：在每条Kafka记录里都嵌入了schema，这会让记录的大小成倍地增加。但是不管怎样，在读取记录时仍然需要用到整个 schema，所以要先找到 schema。有没有什么方法可以让数据共用一个schema？ 我们遵…- 130
- 0
-
Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常？
前几天遇到一个bug，查看发送日志发现java.io.IOException: Broken pipe的错误，通过深入了解发现当kafka producer发送的消息体大于Broker配置的默认值时就会报这个异常。如果仅发送一次是不会报这个异常的，要连续发送才会报这个异常。 本博文记录一下当Kafka发送超过broker限定大小的消息时Client和Broker端各自会有什么异常。 Kafka B…- 16
- 0
-
Flume+kafka+spark streaming+Redis实时统计广告投放的pv,uv,click,cost
因为业务逻辑的修改，投放数据存入大数据集群中，因此，需要修改之前的业务逻辑，需要实时知道rtb投放的花费情况。 环境版本： spark: 2.11-2.4.0-cdh6.2.0 kafka: 2.1.0-cdh6.2.0 fluem: 1.9.0-cdh6.2.0 Flume配置 1a1.sources = r1 2 3a1.sinks = k1 4 5a1.channels = c1 6 7#s…- 73
- 0
-
Java使用RabbitMQ（二）–发送和接收信息
发送和接收信息 发送方： 1public class BaseTest2 { 2 public static String queueName="q1"; 3 4 public static ConnectionFactory factory; 5 public static Connection getConnection(String username,String pas…- 7
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×