logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Spring Boot + Netty+WebSocket+Protobuf 集成通讯配置

目的现在微服务普遍流行,在对外连接上, Netty+Protobuf 通讯性能要优于 Http+Json方式,适合大数据高并发, 长连接异步通讯场景,本教程主要讲解Spring Boot + Netty集成, 以及Netty+WebSocket+Protobuf的通讯配置。脉络Spring Boot 2.X + Netty集成配置Spring Boot 2.X + Netty通讯测试...

【Spring Boot 源码研究 】- 请求处理流程机制分析

之前我们对Spring Boot做了研究讲解,我们知道怎么去集成配置, 知道它如何启动, 如何实现自动化配置,那么它如何接收并处理外部请求, 具体原理是怎样, 又要流转哪些关键环节? filter,interceptor, view是在哪调用, 处理顺序是怎样?Spring Boot 和Spring MVC以及内置容器又是怎样的作用关系?这里我们作具体剖析研究。......

文章图片
#spring boot#java#servlet
深入剖析Zookeeper原理(四)ZK集群数据交互与同步原理

1. 集群数据交互处理流程基于Leader的写操作流程:处理流程:客户端向Leader发起写请求Leader将写请求以Proposal的形式发给所有Follower并等待ACKFollower收到Leader的Proposal后返回ACKLeader得到过半数的ACK(Leader对自己默认有一个ACK)后向所有的Follower和Observer发送CommmitLeader将处理结果返回给客户

文章图片
深入剖析Zookeeper原理(二)ZK集群选举原理

1.PAXOS选举算法Paxos算法概述背景:主流分布式一致性算法包括Paxos,Raft和ZAB,它们之间有怎样的区别与关系?Google Chubby的作者Mike Burrows说过,世上只有一种一致性算法,那就是Paxos,所有其他一致性算法都是Paxos算法的不完整或衍生版。什么是Paxos?Paxos算法是基于消息传递且具有高度容错特性的一致性算法,是目前公认的解决分布式一致性问题最有

深入剖析Zookeeper原理(一)整体设计

1.ZK集群架构设计与特性1. ZK集群架构设计:ZK主要分为三种角色:演示查看ZK的角色状态, 命令: bin/zkServer.sh status角色的主要职责与作用?Leader(领导者):一个Zookeeper集群同一时间只会有一个实际工作的Leader,它会发起并维护与各Follwer及Observer间的心跳。所有的写操作必须要通过Leader完成再由Leader将写操作广播给其它服务

JSON转换为JAVA对象及日期格式转换处理

1.JSON日期格式转换默认JSON对DATE类型会转换成一个多属性对象, 而不是单独的一个字符串, 在某些应用处理上不是很方便,  可以利用JsonValueProcessor来实现日期的转换. 默认格式:"lastUpdate": {                "date": 29,                "day": 3,                "

#json#java
注册程序为LINUX系统服务并设置成自启动

这里以red hat linux 为例,   设置某个JAVA程序为系统服务, 通过service命令进行管理, 并跟随系统自行启动. 1.  先将自己的程序写入SH脚本, 便于管理.如: java -server -cp .:./lib/* com.test.Startup  2. 进入/etc/init.d目录, 新建文件, 以自己的程序命名, 如: erp内容如下:

#linux#java#jar
Flink实时计算运用(六)Flink 连接器的使用

1. Flink Connectors 介绍Flink 连接器包含数据源输入与汇聚输出两部分。Flink自身内置了一些基础的连接器,数据源输入包含文件、目录、Socket以及 支持从collections 和 iterators 中读取数据;汇聚输出支持把数据写入文件、标准输出(stdout)、标准错误输出(stderr)和 socket。官方地址Flink还可以支持扩展的连接器,能够与第三方系统

#flink#kafka#rabbitmq
Flink实时计算运用(七)Flink 自定义序列化Protobuf接入实现方案

1. 自定义序列化接入方案(Protobuf)在实际应用场景中, 会存在各种复杂传输对象,同时要求较高的传输处理性能, 这就需要采用自定义的序列化方式做相应实现, 这里以Protobuf为例做讲解。功能: kafka对同一Topic的生产与消费,采用Protobuf做序列化与反序列化传输, 验证能否正常解析数据。通过protobuf脚本生成JAVA文件syntax = "proto3&q

#flink#kafka#java
    共 15 条
  • 1
  • 2
  • 请选择