-
Spring Cloud构建微服务架构：服务消费（基础）【Dalston版】
通过上一篇《Spring Cloud构建微服务架构：服务注册与发现》，我们已经成功地将服务提供者：eureka-client或consul-client注册到了Eureka服务注册中心或Consul服务端上了，同时我们也通过DiscoveryClient接口的getServices获取了当前客户端缓存的所有服务清单，那么接下来我们要学习的就是：如何去消费服务提供者的接口？ 使用LoadBalanc…- 12
- 0
-
SpringCloud微服务搭建详解
主要讲解SpringCloud搭建微服务的步骤，其中用到了Eurake、Ribbon、Feign、Hystrix、Zuul、Config技术。 项目地址：https://github.com/17665387407?tab=repositories 一、建立一个总工程 首先建立一个microservice-parent总工程，总工程中并不做什么业务逻辑，总工程主要定义一个POM文件，将后续各个…- 7
- 0
-
Netty游戏服务器实战开发(9):利用redis或者zookeeper实现3pc分布式事务锁（三）。支撑腾讯系列某手游百万级流量公测
导读：在编写前面两篇文章的时候，博主其实已经把这个项目做完了，因为不可能一边写文章，一遍写项目。所以我都是把项目做完之后然后通过自己测试之后确保没有问题就来编写文章。 最近估计大家都听说了“华夏银行技术处长编写病毒植入系统，盗窃 700 余万受审”按键沸沸扬扬。很多人就想知道，如此可爱的程序员宝宝如何走向犯罪的道路，所以不管出于人性和社会道德，技术人员还是不要轻易的在系统中留下后门程序。否者被查出…- 18
- 0
-
Netty源码分析第5章(ByteBuf)—->第3节: 缓冲区分配器
Netty源码分析第五章: ByteBuf 第三节: 缓冲区分配器 缓冲区分配器 , 顾明思议就是分配缓冲区的工具 , 在 netty中 , 缓冲区分配器的顶级抽象是接口 ByteBufAllocator, 里面定义了有关缓冲区分配的相关 api 抽象类 AbstractByteBufAllocator实现了 ByteBufAllocator接口 , 并且实现了其大部分功能 和 Abs…- 0
- 0
-
Netty源码分析第2章(NioEventLoop)—->第8节: 执行任务队列
** ** Netty源码分析第二章: NioEventLoop ** ** 第八节: 执行任务队列 继续回到NioEventLoop的run()方法: 1protected void run() { 2 for (;;) { 3 try { 4 switch (selectStrategy.calculateStrategy(selectNowSupplier, hasTasks())) { 5…- 4
- 0
-
Netty In Action中文版 – 第十二章：SPDY
Netty In Action中文版 - 第十二章：SPDY 本章我将不会直接翻译Netty In Action书中的原文，感觉原书中本章讲的很多废话，我翻译起来也吃力。所以，本章内容我会根据其他资料和个人理解来讲述。 12.1 SPDY概念及背景 SPDY是Google开发的基于传输控制协议（TCP）的应用层协议，开发组正在推动SPDY成为正式标准（现为互联网草案）.SPDY协议…- 5
- 0
-
Netty In Action中文版 – 第三章：Netty核心概念
Netty In Action中文版 - 第三章：Netty核心概念 在这一章我们将讨论Netty的10个核心类，清楚了解他们的结构对使用Netty很有用。可能有一些不会再工作中用到，但是也有一些很常用也很核心，你会遇到。 Bootstrap or ServerBootstrap EventLoop EventLoopGroup ChannelPipeline Channel Future or …- 0
- 0
-
Mina、Netty、Twisted一起学（一）：实现简单的TCP服务器
MINA、Netty、Twisted为什么放在一起学习？首先，不妨先分别看一下它们官方网站对其的介绍： MINA： Apache MINA is a network application framework which helps users develop high performance and high scalability network applications easily. It…- 4
- 0
-
Java NIO框架Netty教程(七)-再谈收发信息次数问题
在《Java NIO框架Netty教程（五）- 消息收发次数不匹配的问题》里我们试图分析一个消息收发次数不匹配的问题。当时笔者还是心存疑惑的。所以决定先学习一下Java NIO的Selector机制。 经过简单的了解，笔者大胆的猜测和“武断”一下该问题的原因。 首先，Selector机制让我们注册一个感兴趣的时间，然后只要有该时间发生，就会传递给接收端。我们写了三次，接收端一定会出发三次的。 然后…- 16
- 0
-
netty实现websocket
1.搭建springboot web 项目，参考 https://blog.csdn.net/u013184307/article/details/98057621 2.导入包 1<dependency> 2 <groupId>io.netty</groupId> 3 <artifactId>netty-all</artifactId> …- 9
- 0
-
SpringBoot整合Netty
文章目录 1.依赖 2.配置文件 3.项目结构 4.启动类 5.netty启动类 6.netty配置类 1.依赖 1<?xml version="1.0" encoding="UTF-8"?> 2<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi=&q…- 38
- 0
-
基于Dubbo框架构建分布式服务
转自：http://shiyanjun.cn/archives/1075.html 很好的文章 Dubbo是Alibaba开源的分布式服务框架，我们可以非常容易地通过Dubbo来构建分布式服务，并根据自己实际业务应用场景来选择合适的集群容错模式，这个对于很多应用都是迫切希望的，只需要通过简单的配置就能够实现分布式服务调用，也就是说服务提供方（Provider）发布的服务可以天然就是集群服务，比如，…- 4
- 0
-
RabbitMQ VS Apache Kafka （九）—— RabbitMQ集群的分区容错性与高可用性
本章，我们讨论有关RabbitMQ的容错性，消息一致性及高可用性。RabbitMQ可以作为集群节点来运行，因此RabbitMQ通常被归为分布式消息系统，对于分布式消息系统，我们的关注点通常是一致性与可用性。 我们为什么要讨论分布式系统的一致性与可用性，本质在于两者描述的是系统在失败的情况下表现如何。在实际应用中，网络连接失败、服务器宕机，硬盘损坏，服务器由于GC暂时不可用，网络连接丢失或速度慢，所…- 9
- 0
-
RabbitMQ VS Apache Kafka （一）—— RabbitMQ简介
在接下来的系列章节中，我们将探讨两种消息中间件RabbitMQ与Apache Kafka，从设计的角度来看，作为两种不同的消息中间件，各自都有自己的技术考究，也都有一定的优缺点。本章，我们将不会去评判孰优孰劣，而是作为接下来本系列的引言或者入门。 RabbitMQ RabbitMQ是一个分布式的消息队列系统。之所以说是分布式，因为它通常作为节点集群运行，这其中队列分布在节点上，并可选择复制以实现分…- 8
- 0
-
Kafka的Log存储解析
引言 Kafka中的Message是以topic为基本单位组织的，不同的topic之间是相互独立的。每个topic又可以分成几个不同的partition(每个topic有几个partition是在创建topic时指定的)，每个partition存储一部分Message。借用官方的一张图，可以直观地看到topic和partition的关系。 partition是以文件的形式存储在文件系统中，比如，创…- 8
- 0
-
Kafka+Spark Streaming+Redis实时计算整合实践
基于Spark通用计算平台，可以很好地扩展各种计算类型的应用，尤其是Spark提供了内建的计算库支持，像Spark Streaming、Spark SQL、MLlib、GraphX，这些内建库都提供了高级抽象，可以用非常简洁的代码实现复杂的计算逻辑、这也得益于Scala编程语言的简洁性。这里，我们基于1.3.0版本的Spark搭建了计算平台，实现基于Spark Streaming的实时计算。 我们…- 14
- 0
-
Java使用RabbitMQ（四）–消息持久化
消息持久化 消息确认，保证了消费者die时，消息不丢失。 而消息持久化，则是为了保证RabbitMQ 怠机时，消息不丢失。 消息持久化需要以下操作： 1boolean durable = true; 2channel.queueDeclare("hello", durable, false, false, null); 3 需要注意的是，RabbitMQ不允许修改已经定义过的队…- 12
- 0
-
C# 操作rabbitmq（四）
此篇介绍rabbitmq的Topic 一、 虽然Routing可以让我们用更适合于工作业务的方式操作消息队列，但还是存在一定的局限性，例如不能同时适应多个，比如我们不仅想要监听来自cron的错误消息，也要坚定kern的消息，而Topic类型的exchange可以解决这个问题。 二、 Topic exchange topic exchange 发送的消息，routing-key不能是任意的，必须是一…- 8
- 0
-
AMQP-RabbitMQ/3/发布订阅模式
3. 发布订阅模式 Publish/Subscribe - 全集监听fanout 一次向多个消费者发送消息 图示 个人理解 生产者定义Exchange，同时将Exchange的类型定义为fanout，并向该Exchange发送消息。 消费者定义队列Queue，并将队列与该交换机进行绑定。之后交换机付负责将消息全量推送给每一个与之绑定的Queue **RabbitMQ中消息传递模型的核心思想是生产者…- 13
- 0
-
基于Python语言使用RabbitMQ消息队列（五）
Topics 在前面教程中我们改进了日志系统，相比较于使用fanout类型交易所只能傻瓜一样地广播，我们用direct获得了选择性接收日志的能力。 虽然使用direct类型交易所改进了我们的系统，但它仍然有所限制——它不能做基于多重条件（multiple criteria）的路由。 在日志系统中我们可能不只是想要基于严重级别来订阅日志。也想要基于产生日志的来源。你可能从unix的系统日志工具（sy…- 2
- 0
-
rabbitMq实现延时队列
rabbitMq是受欢迎的消息中间件之一，相比其他的消息中间件，具有高并发的特性（天生具备高并发高可用的erlang语言编写），除此之外，还可以持久化，保证消息不易丢失，高可用，实现集群部署，提供灵活的路由和可靠性，可视化管理等等的优点。 相比于其他的消息队列，rabbitmq最大的特色就是加入了exchange（交换器）这个东西，AMQP协议中的核心思想就是生产者和消费者隔离，生…- 12
- 0
-
分布式存储与分布式计算
目录 1、从一个新闻门户网站案例引入 2、推算一下你需要分析多少条数据？ 3、黄金搭档：分布式存储+分布式计算 这篇文章聊一个话题：什么是分布式计算系统？ （1）从一个新闻门户网站案例引入 现在很多同学经常会看到一些名词，比如分布式服务框架，分布式系统，分布式存储系统，分布式消息系统。 但是有些经验尚浅的同学，可能都很容易被这些名词给搞晕。所以这篇文章就对“分布式计算系统”这个…- 10
- 0
-
分布式并行计算MapReduce
1.用自己的话阐明Hadoop平台上HDFS和MapReduce的功能、工作原理和工作过程。 HDFS 功能： 分布式文件系统，用来存储海量数据。 工作原理和过程：HDFS是Hadoop的分布式文件系统，HDFS中的文件会默认存储3份，存储在不同的机器上，提供容错机制，副本丢失或者宕机的自动恢复。HDFS总体上采用Master/Slave的架构，整个HDFS架构由Client、Na…- 9
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×