-
Netty源码分析第2章(NioEventLoop)—->第4节: NioEventLoop线程的启动
Netty源码分析第二章: NioEventLoop ** ** 第四节: NioEventLoop线程的启动 之前的小节我们学习了 NioEventLoop 的创建以及线程分配器的初始化 , 那么 NioEventLoop 是如何开启的呢 , 我们这一小节继续学习 NioEventLoop 的开启方法在其父类 SingleThreadEventExecutor中的 execute(Run…- 8
- 0
-
Netty源码分析第1章(Netty启动流程)—->第3节: 服务端channel初始化
Netty源码分析第1章(Netty启动流程)---->第3节: 服务端channel初始化 Netty源码分析第一章:Netty启动流程 ** ** 第三节:服务端channel初始化 回顾上一小节的initAndRegister()方法: 1final ChannelFuture initAndRegister() { 2 Channel channel = null; 3 tr…- 2
- 0
-
MINA、Netty、Twisted一起学(十二):HTTPS
由于HTTPS协议是由HTTP协议加上SSL/TLS协议组合而成,在阅读本文前可以先阅读一下HTTP服务器和SSL/TLS两篇博文,本文中的代码也是由这两篇博文中的代码组合而成。 HTTPS介绍 窃听隐私:使用明文传输的HTTP协议,传输过程中的信息都可能会被攻击者窃取到,例如你登录网站的用户名和密码、在电商的购买记录、搜索记录等,这就会造成例如账号被盗、各种隐私泄漏的风险。而使用HTTPS对通信…- 15
- 0
-
Java NIO框架Netty教程 (七) 消息收发次数不匹配的问题
上回通过代码理解了Netty底层信息的流的传递机制,不过只是一个感性上的认识。教会你应该如何使用和使用的时候应该注意的方面。但是有一些细节的问题,并没有提及。比如: view sourceprint? private void sendMessageByFrame(ChannelStateEvent e) { String msgOne = "Hello, "; String …- 11
- 0
-
-
Netty websocket
Network protocols WebSocket是一种高级网络协议,旨在提高Web应用程序的性能和响应能力。 我们将通过编写示例应用程序来探索Netty对它们的支持。 在第12章中,您将学习如何使用WebSocket实现双向数据传输,方法是构建一个聊天室服务器,其中多个浏览器客户端可以实时通信。 您还将看到如何通过检测客户端是否支持它,从应用程序中的HTTP切换到WebSocket协议。 我…- 135
- 0
-
Springcloud微服务项目——人力资源管理(HRM)Day06 ElasticSearch
今日任务 课程的CRUD 关于数据库的存储 有两种方案 方案一: 像课程详情 课程图片 都是数据课程的信息 可知直接放入t_course 就ok 方案二: 有时候我们只需要查询到课程的基本信息 不需要显示图片和详情 这个时候我们就会用到垂直分表 垂直分表:一些字段我们一般不需要直接查询 就把这些字段单独放一个表 通过外键关联 正常情况下 不需要查询关联表 如果需要 就通过外键查询就ok 这样能大大…- 10
- 0
-
kafka原理和实践(六)总结升华
目录 总结篇 1.官方介绍 2.特点 3.Kafka的设计 4.Kayka的应用场景 5.总结 正文 系列目录 kafka原理和实践(一)原理:10分钟入门 kafka原理和实践(二)spring-kafka简单实践 kafka原理和实践(三)spring-kafka生产者源码 kafka原理和实践(四)spring-kafka消费者源码 kafka原理和实践(五)spring-kafka配置…- 8
- 0
-
kafka原理和实践(一)原理:10分钟入门
目录 一、kafka拓扑图 二、名词解释 三、生产模型 四、消费模型 正文 系列目录 kafka原理和实践(一)原理:10分钟入门 kafka原理和实践(二)spring-kafka简单实践 kafka原理和实践(三)spring-kafka生产者源码 kafka原理和实践(四)spring-kafka消费者源码 kafka原理和实践(五)spring-kafka配置详解 kafka原理和实践…- 3
- 0
-
如何管理Spark Streaming消费Kafka的偏移量(一)
本篇我们先从理论的角度聊聊在Spark Streaming集成Kafka时的offset状态如何管理。 spark streaming 版本 2.1 kafka 版本0.9.0.0 在这之前,先重述下spark streaming里面管理偏移量的策略,默认的spark streaming它自带管理的offset的方式是通过checkpoint来记录每个批次的状态持久化到HDFS中,如果机器发生故障…- 18
- 0
-
rocketMq和kafka的架构区别
概述 其实一直想写一篇rocketMq和kafka在架构设计上的差别,但是一直有个问题没搞明白所以迟迟没动手,今天无意中听人点播了一下似乎明白了这个问题,所以就有了这篇对比。 这篇博文主要讲清楚kafka和rocketMq的两个不同点,1、rocketMq的namesvr和kafka的zookeeper对比;2、kafka为什么比rocketMq有更大的吞吐量。如果能够讲清楚上面两…- 10
- 0
-
Docker下RabbitMQ四部曲之三:细说java开发
本文是《Docker下RabbitMQ四部曲》系列的第三篇,实战两个基于SpringBoot的工程,分别用来生产和消费RabbitMQ消息; 本文内容简述 今天的实战由以下几部分组成: 开发SpringBoot工程rabbitmqproducer,用来生产消息; 分析docker-compose.yml中对rabbitmqproducer镜像的使用; 开发SpringBoot工程rabbitmqc…- 18
- 0
-
使用Zabbix监控RabbitMQ
一 应用场景描述 线上业务使用RabbitMQ作为消息队列中间件,那么作为运维人员对RabbitMQ的监控就很重要,本文就针对如何从头到尾使用Zabbix来监控RabbitMQ进行说明。 二 RabbitMQ监控要点 RabbitMQ官方提供两种方法来管理和监控RabbitMQ。 1.使用rabbitmqctl管理和监控 Usage: rabbitmqctl [-n <node>] […- 90
- 0
-
AMQP-RabbitMQ/1/概念/一对一简单模型
# JMS,AMQP,MQTT的区别与联系 JMS Java消息传递服务(Java Messaging Service ) AMQP 高级消息队列协议(Advanced Message Queueing Protocol ) MQTT 消息队列遥测传输(Message Queueing Telemetry Transport ) 简单理解: *JMS是专门为Java设计的一套消息服务API,像Ac…- 15
- 0
-
RabbitMQ消息队列(四):分发到多Consumer(Publish/Subscribe)
上篇文章中,我们把每个Message都是deliver到某个Consumer。在这篇文章中,我们将会将同一个Message deliver到多个Consumer中。这个模式也被成为 "publish / subscribe"。 这篇文章中,我们将创建一个日志系统,它包含两个部分:第一个部分是发出log(Producer),第二个部分接收到并打印(Consumer)。 我们将构建…- 6
- 0
-
RabbitMQ安装
部署安装RabbitMQ前,先了解下基本概念:(RabbitMQ+Python入门经典] 兔子和兔子窝) RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连…- 30
- 0
-
rabbitMQ基础
目录 jar包 消息类型 简单模型Hello Word 工作队列模式Work Queue Round-robin (轮询分发) Fair dispatch (公平分发) 订阅 模式 Publish/Subscribe 路由模式 通配符模式Topic RabbitMQ 之消息确认机制(事务+Confirm ) 概述 事务机制 Confirm 模式 jar包 1<dependency&g…- 7
- 0
-
分布式与集群的区别是什么?
分布式:一个业务分拆多个子业务,部署在不同的服务器上 集群:同一个业务,部署在多个服务器上 单机结构 我想大家最最最熟悉的就是单机结构,一个系统业务量很小的时候所有的代码都放在一个项目中就好了,然后这个项目部署在一台服务器上就好了。整个项目所有的服务都由这台服务器提供。这就是单机结构。 那么,单机结构有啥缺点呢?我想缺点是显而易见的,单机的处理能力毕竟是有限的,当你的业务增长到一定程度的时候,单机…- 7
- 0
-
-
SpringBoot+zk+dubbo架构实践(一):本地部署zookeeper
SpringBoot+zk+dubbo架构实践系列实现目标 本地部署zookeeper SpringBoot 集成 zookeeper Dubbo-admin管理平台安装 SpringBoot+ zookeeper +dubbo 框架搭建 架构业务实践(实现电商部分业务) 备注:本系列偏向于动手实践,不讲太多理论。 前言 本文操作都是在Mac上进行的,如果大家用的windows 可以相对应的进行修…- 1
- 0
-
JFinal 中使用 Dubbo —— 2 部署及运行
1. 部署及运行 1.1. 部署 请参见“ JFinal 教程 1部署应用到Tomcat的步骤讲得比较详细。部署后结构如下图: 可以看到, Consumer 和 Provider 都依赖 Api 项目。 1.2. 运行 Consumer 和 Provider 无论谁先启动都可以,输入 URL 后,可以看到 JFinal Demo 原装页面了: 查看管制台, Provider 输出…- 3
- 0
-
Dubbo的使用及原理浅析
Dubbo是什么? Dubbo是阿里巴巴SOA服务化治理方案的核心框架,每天为2,000+个服务提供3,000,000,000+次访问量支持,并被广泛应用于阿里巴巴集团的各成员站点。 Dubbo[]是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案。 其核心部分包含: 远程通讯: 提供对多种基于长连接的NIO框架抽象封装,包括多种线程模型,序列化,以及“…- 2
- 0
幸运之星正在降临...
点击领取今天的签到奖励!
恭喜!您今天获得了{{mission.data.mission.credit}}积分
我的优惠劵
-
¥优惠劵使用时效:无法使用使用时效:
之前
使用时效:永久有效优惠劵ID:×
没有优惠劵可用!















