-
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表…- 10
- 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…- 74
- 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
-
.Net下RabbitMQ的使用(9) — 在WCF下使用RabbitMQ
RabbitMQ .net客户端通过自定义的Binding和Transport Binding Element扩展了WCF，使之能够在AMQP协议上使用。在WCF中，Binding作为一系列Binding Elements的栈，控制了消息传输的大部分方面如安全，消息格式，事务等等。而Binding中的Transport Binding Element传输绑定元素，则指定了服务端和客户端之间的通信协…- 15
- 0
-
AMQP-RabbitMQ/2/工作队列
2. 工作队列 Work queues Distributing tasks among workers 消息将发送给c1或者c2 个人理解 生产者定义Queue，并向该队列发送消息 多个消费者可以从指定的同一个Queue中读取消息。每条消息只会发送给其中某一个消费者。 生产者 1package com.futao.springmvcdemo.mq.rabbit.workqueue; 2 3imp…- 9
- 0
-
基于Python语言使用RabbitMQ消息队列（三）
发布/订阅 前面的教程中我们已经创建了一个工作队列。在一个工作队列背后的假设是每个任务恰好会传递给一个工人。在这一部分里我们会做一些完全不同的东西——我们会发送消息给多个消费者。这就是所谓的“发布/订阅”模式。 为了解释这种模式，我们将会构建一个简单的日志系统。它包含两个程序——第一个产生日志消息，第二个接收并把他们打印出来。 在我们的日志系统中，每一个接收程序的正在运行的拷贝都会获知消息，那样我…- 17
- 0
-
分布式Session的几种实现方式
一。分布式Session的几种实现方式 1.基于数据库的Session共享 2.基于NFS共享文件系统 3.基于memcached 的session，如何保证 memcached 本身的高可用性？ 基于resin/tomcat web容器本身的session复制机制 基于TT/Redis 或 jbosscache 进行 session 共享。 基于cookie 进行session共享 或者是： 一…- 13
- 0
-
RabbitMQ基本概念
RabbitMQ基本概念 RabbitMQ简介 RabbitMQ的特点 RabbitMQ核心概念 Producer(生产者) 和 Consumer(消费者) Exchange(交换器) Queue(消息队列) Broker（消息中间件的服务节点） RabbitMQ简介 RabbitMQ是采用Erlang语言实现AMQP(Advanced Message Queuing Protocol）的消息中间…- 29
- 0
-
windows下安装rabbitMQ
博客地址：博客地址 本文转自：https://www.cnblogs.com/ericli-ericli/p/5902270.html 本文转自：https://www.cnblogs.com/ericli-ericli/p/5902270.html rabbitMQ是一个在AMQP协议标准基础上完整的，可服用的企业消息系统。它遵循Mozilla Public License开源协议，采用 E…- 7
- 0
-
14. Dubbo原理解析-集群&容错之Cluster
Dubbo作为一个分布式的服务治理框架，提供了集群部署，路由，软负载均衡及容错机制 下图描述了dubbo调用过程中的对于集群，负载等的调用关系。 Cluster 将Directory中的多个Invoker伪装成一个Invoker, 对上层透明，包含集群的容错机制 Cluster接口定义 @SPI(FailoverCluster.NAME) public interface Cluster …- 5
- 0
-
SpringBoot+zk+dubbo架构实践（三）：部署Dubbo-admin管理平台
上一篇：SpringBoot+zk+dubbo架构实践（二）：SpringBoot 集成 zookeeper 前言 1我们的架构实践已经进行一半了，今天这波操作比较轻松哦。同样我们完成两件事情。 21、Dubbo Git下载（2.6.0版本） 32、dubbo-admin安装和验证 4 再次声明一下：本系列架构实践不做深入探讨，主旨是带领大家能够快速踏入微服务架构门槛，能够轻松的搭建一套属于自己的…- 13
- 0
-
初识Dubbo 系列之3-Dubbo 快速启动
快速启动 (+) (#) Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。 1 如果不想使用Spring配置，而希望通过API的方式进行调用（不推荐），请参见：API配置 (+) 1 链接地址服务提供者 (#) 完整安装步骤，请参见：示例提供者安装 (+) 1 定义服务…- 27
- 0
-
Apache 开源的curator 基于Zookeeper实现分布式锁以及源码分析
前一段时间，我发表了一篇关于Redis实现分布式锁 分布式环境下利用Redis实现分布式锁，今天我带领大家熟悉用zookeeper实现分布式锁。 在学习分布式锁之前，让我们想一想，在什么业务场景下会用到分布式锁以及设计分布式锁要注意什么？ 分布式锁介绍 1、在什么业务场景中会使用到分布式锁 当多个客户端访问服务器上同一个资源的时候，需要保证数据的一致性，比如秒杀系统，举个栗子： 某件商品在系统中的…- 12
- 0
-
curator分布式锁
长长的一生，总要勤勤恳恳，刻苦专研。把一件事情做到极致，不然，岂非白活了？ 之前看kafka的时候发现他用的是curator来做leader选举的，突然灵机一动，咦，这不就是把ZK分布式锁封装了一下嘛，咦，那是不是这个也可以做分布式锁呢？“好奇心害死猫”，赶紧在pom里面dependency一下，抓下来源码来看看到底怎么肥事。先把源码贴上，具体的分析自己先分析一波，分析之后找时间再补充上来!!! …- 10
- 0
-
Golang 通过 Consul 实现分布式锁
Consul 是什么 Consul 是一个支持多数据中心分布式高可用的服务发现和配置共享的服务软件,由 HashiCorp 公司用 Go 语言开发, 基于 Mozilla Public License 2.0 的协议进行开源. Consul 支持健康检查,并允许 HTTP 和 DNS 协议调用 API 存储键值对. 命令行超级好用的虚拟机管理软件 vgrant 也是 HashiCorp 公司开发的…- 10
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×