-
Mina、Netty、Twisted一起学（八）：HTTP服务器
HTTP协议应该是目前使用最多的应用层协议了，用浏览器打开一个网站就是使用HTTP协议进行数据传输。 HTTP协议也是基于TCP协议，所以也有服务器和客户端。HTTP客户端一般是浏览器，当然还有可能是其他东西。HTTP服务器，也就是Web服务器，目前已经有很多成熟的产品，例如Apache HTTP Server、Tomcat、Nginx、IIS等。 本文的内容不是讲解如何使用以上的HTTP服务器，…- 4
- 0
-
Java NIO框架Netty教程 (十) Object对象编/解码
看到题目，有的同学可能会想，上回不是说过对象传递了吗？是的，只是在Java NIO框架Netty教程(八) Object对象传递中，我们只是介绍如何使用Netty提供的编/解码工具，完成对象的序列化。这节是想告诉你Netty具体是怎么做的，也许有的同学想自己完成序列化呢？况且，对象的序列化，随处可用：） 先看怎么编码。 view sourceprint? @Override protected O…- 4
- 0
-
用Netty实现的简单HTTP服务器
用Netty实现的一个简单的HTTP服务器，可以处理静态文件，例子中的注释也比较全。主要是对HTTP的理解，接下来的文章中我也会更新一些HTTP相关的文章以及对例子的进一步完善，由浅到深，记录一些我的学习过程！ 1.Server 2.Pipeline 3.handler类 4.配置类- 8
- 0
-
RabbitMQ VS Apache Kafka （九）—— RabbitMQ集群的分区容错性与高可用性
本章，我们讨论有关RabbitMQ的容错性，消息一致性及高可用性。RabbitMQ可以作为集群节点来运行，因此RabbitMQ通常被归为分布式消息系统，对于分布式消息系统，我们的关注点通常是一致性与可用性。 我们为什么要讨论分布式系统的一致性与可用性，本质在于两者描述的是系统在失败的情况下表现如何。在实际应用中，网络连接失败、服务器宕机，硬盘损坏，服务器由于GC暂时不可用，网络连接丢失或速度慢，所…- 4
- 0
-
Kafka实战(五) – Kafka的秘技"坂本"之争
只有顺应版本,才能成就王者不败神话 也是能否用好Kafka的关键。 不论是哪种Kafka，本质上都基于core Apache Kafka 那就来说说Apache Kafka版本号的问题 1 缘何"在乎"你这版本号 直接使用最新版本不就好了吗？ 当然了!这的确是一种有效策略，这种策略并非在任何场景下都适用 如果不了解各个版本之间的差异和功能变化，怎么能够准确地评判某Kafka版本…- 24
- 0
-
RabbitMQ VS Apache Kafka （五）—— RabbitMQ路由拓扑与消息模式
本章我们讨论RabbitMQ的消息模式与路由拓扑，主要涉及以下知识点： 交换器类型与绑定关系 消息队列 死信交换器 即时交换器与队列 备用交换器 优先级队列 交换器类型 1. 扇出交换器 扇出交换器提供了典型的发布订阅消息拓扑，发送到扇出交换器中的消息将会广播路由到所有绑定到当前交换器上的所有消息队列和交换器中。 在扇出交换器中，消费者彼此间相互独立，彼此收到的也只是消息的拷贝。如果需要对Cons…- 11
- 0
-
Kafka 中使用 Avro 序列化框架(一)：使用传统的 avro API 自定义序列化类和反序列化类
关于 avro 的 maven 工程的搭建以及 avro 的入门知识，可以参考： Apache Avro 入门 1. 定义 schema 文件，并编译 maven 工程生成实体类 schema 文件名称为：stock.avsc，内容如下： 1 2{ 3 "namespace": "com.bonc.rdpe.kafka110.beans", 4 "…- 9
- 0
-
如何收集项目日志统一发送到kafka中？
如何在普通应用程序实时收集日志 所谓的普通程序就是web项目的或者非web项目的的程序，大部分都是单机版本的。 大多数时候，我们的log都会输出到本地的磁盘上，排查问题也是使用Linux命令来搞定，如果web程序组成负载集群，那么就有多台机器，如果有几十台机器，几十个服务，那么想快速定位log问题和排查就比较麻烦了，所以很有必要有一个统一的平台管理log，现在大多数公司的套路都是收集重要应用的lo…- 11
- 0
-
使用Log4j将程序日志实时写入Kafka
第一部分 搭建Kafka环境 安装Kafka 下载：http://kafka.apache.org/downloads.html 1tar zxf kafka-<VERSION>.tgz 2cd kafka-<VERSION> 3 启动Zookeeper 启动Zookeeper前需要配置一下config/zookeeper.properties： 接下来启动Zookeep…- 16
- 0
-
Java使用RabbitMQ（一）–基本用法
关于java使用rabbitMq的基本用法 创建连接 1 2 public static ConnectionFactory factory; 3 public static Connection getConnection(String username,String password,String host,int port,String virtualhost) { 4 if (factor…- 2
- 0
-
学会查看 RabbitMQ日志
如果在使用RabbitMQ的过程中出现了异常情况，通过翻阅RabbitMQ的服务日志可以让你在处理异常的过程中事半功倍。RabbitMQ日志中会有明确的事件日期、事件内容以及事件等级等。RabbitMQ的日志默认存放在$RABBITMQ_HOME/var/log/rabbitmq目录下。本问主要从RabbitMQ服务开启、RabbitMQ服务关闭以及RabbitMQ集群搭建的角度来举例说明Rabb…- 26
- 0
-
.Net下RabbitMQ的使用(4) — 订阅和发布
消息的订阅和发布是使用消息队列的常用场景。在上一篇文章中，虽然有多个消费者，但是一个消息只会有一个消费者来处理。而订阅和发布则是每个订阅该消息的消费者都会收到这个消息。RabbitMQ的路由机制让我们实现这个功能轻而易举。 要了解RabbitMQ的路由机制，exchange是一个关键。exchange可以叫做交换机，也似乎可以叫做路由器，反正它是用来选择路由的。前文说到，RabbitMQ的核心…- 21
- 0
-
RabbitMQ使用详解
刚刚用了，记录下来，以后忘了，方便能够快速想起来。 首先说明，由于RabbitMQ服务端非JAVA,C++语言，当然也就看不懂，所以本文的理解都是过于主观的。 一，RabbitMQ服务端搭建 推荐最好的安装方式：去官网，去官网，去官网，重要的事情说三遍。 我一般的操作流程是：用google右上角翻译网页，然后看个大概意思，然后再显示原网页，一个单词单词的看。 还是总结一下Ubuntu,Rabbit…- 25
- 0
-
Centos7 安装rabbitMQ
RabbitMQ的基本原理 首先需要安装erlang，根据rabbitMQ的版本不同安装的erlang版本也不一样： erlang与rabbitMQ版本关系 我的系统是centos7 、Erlang 20.x rabbitMQ 3.6.11. 第一步添加yum源 1# vi /etc/yum.repos.d/rabbitmq-erlang.repo 2 3 1添加如下内容： 2[rabbitmq-…- 8
- 0
-
Memcache分布式部署方案
前言 应该是很久之前，我开始研究Memcache，写了一系列的学习心得，比如《Discuz!的Memcache缓存实现》等。后面的好几十条回复也让这篇文章成为了此博客中颇受关注的一员。 同时在百度和Google，关键词Memcache在长达一年多的时间里占据着第二位（第一位是官方），为很多需要了解或者应用Memcache的朋友提供了一些信息，但是我始终觉着还不够，于是本文诞生。 唠唠叨叨说了半天，…- 2
- 0
-
分布式日志收集框架Flume
分布式日志收集框架Flume 1.业务现状分析 WebServer/ApplicationServer分散在各个机器上 想在大数据平台Hadoop进行统计分析 日志如何收集到Hadoop平台上 解决方案及存在的问题 如何解决我们的数据从其他的server上移动到Hadoop之上？ shell: cp --> Hadoop集群的机器上，hdfs dfs -put ....（有很多问题不好解决，…- 26
- 0
-
23. Dubbo原理解析-编码解码之Codec2接口定义
Dubbo的远程调用需要对传输的数据进行编码解码，dubbo的Codec2接口定义了编码解码规范，与废弃的接口Codec相比，Codec2没有依赖jdk的输入输出流， 以dubbo的ChannelBuffer为核心便于更好的整合 @SPI public interface Codec2 { @Adaptive({Constants.CODEC_KEY}) void encode(C…- 23
- 0
-
17. Dubbo原理解析-集群&容错之负载均衡
LoadBalance负载均衡， 负责从多个 Invokers中选出具体的一个Invoker用于本次调用，调用过程中包含了负载均衡的算法，调用失败后需要重新选择 LoadBalance接口定义 @SPI(RandomLoadBalance.NAME) public interface LoadBalance{ @Adaptive( "loadbalance") <T>…- 5
- 0
-
初识Dubbo 系列之2-Dubbo用法
用法 (#) 本地服务：(Spring配置) local.xml 1< 2 bean 3 id=“xxxService” class=“com.xxx.XxxServiceImpl” /> 4 5 6 7 8 9 10 11 12 13 14 15 < 16 bean 17 id=“xxxAction” class=“com.xxx.XxxAction”> 18 19 …- 9
- 0
-
ZooKeeper分布式锁实现java例子，附完整可运行源代码
本原创入门教程，涵盖ZooKeeper核心内容，通过实例和大量图表，结合实战，帮助学习者理解和运用，任何问题欢迎留言。 目录： zookeeper介绍与核心概念 安装和使用 ZooKeeper分布式锁实现 ZooKeeper框架Curator分布式锁实现及源代码分析 zookeeper 开发实战（java客户端） 分布式锁有多种实现方式，比如通过数据库、redis都可实现。作为分布式协同工具Zoo…- 55
- 0
-
Redisson实现Redis分布式锁的N种姿势
前几天发的一篇文章《Redlock：Redis分布式锁最牛逼的实现》，引起了一些同学的讨论，也有一些同学提出了一些疑问，这是好事儿。本文在讲解如何使用Redisson实现Redis普通分布式锁，以及Redlock算法分布式锁的几种方式的同时，也附带解答这些同学的一些疑问。 Redis几种架构 Redis发展到现在，几种常见的部署架构有： 单机模式； 主从模式； 哨兵模式； 集群模式； 我们首先基于…- 58
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day10 用户管理(图片验证码 手机验证码)
用户管理 老规矩 先新建用户模块 这里没有客户端模块 是因为用户模块是一个单独的模块 不用服务之间的调用 导入总的依赖 1<dependencies> 2 3 <!--所有provider公共依賴--> 4 <dependency> 5 <groupId>org.leryoo</groupId> 6 <artifactId>h…- 8
- 0
-
￥优惠劵使用时效：无法使用使用时效：
之前
使用时效：永久有效优惠劵ID：×