最新动态

聊聊Kafka分区、producer、consumer

一. Kafka topic消息根据什么规则推送到到指定区partition?1) 发布消息时,如果只传了topic没有传key,则会以topic随机计算出一个的区(partition)来存放消息。优点:消息分布到不同partition上,能并发消费(并发数小于等于分区总数),消费速度快。缺点:不保...

MINA框架开发入门--简单易用的基于TCP/IP通信的JAVA框架

简单介绍MINA是apache下的一个开源项目,是一个网络通信应用框架,也就是说,它主要是对基于TCP/IP、UDP/IP协议栈的通信框架(然,也可以提供JAVA 对象的序列化服务、虚拟机管道通信服务等),Mina 可以帮助我们快速开发高性能、高扩展性的网络通信应用,Mina 提供了事件驱动、异步(...

Kafka入门教程 经典教程

一、基本概念介绍Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。 这个独特的设计是什么样的呢? 首先让我们看几个基本的消息系统术语: Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers....

Kafka丢数据?Kafka如何预防丢数据?

Kafka到底会不会丢数据(data loss)? 通常不会,但有些情况下的确有可能会发生。下面的参数配置及Best practice列表可以较好地保证数据的持久性(当然是trade-off,牺牲了吞吐量)。笔者会在该列表之后对列表中的每一项进行讨论,有兴趣的同 学可以看下后面的分析。bloc...

Kafka的三种消费模式

自动提交offset以下实例代码展示了如何自动提交topic的offset:public void autoOffsetCommit() { Properties props = new Properties(); props.put("bootstra...

Druid监控SSM项目性能-配置与实例

介绍以前弄项目的时候,也没配置druid性能监控,但是随着用户的增多,有的时候网站访问慢了,就想知道哪个地方遇到了性能问题,然后好对方法以及sql进行优化,该加索引的加索引,该缓存的去缓存。Druid是阿里巴巴开源平台上一个数据库连接池实现(网上都说这个是目前java最好的连接池)。Druid还能够...

Java 工作2年后需要达到怎么样的技术水平

请具体一点说要会什么技术?以及这些技术要达到什么水平?有人回答说这只能是大企业或者互联网企业的工程师才能拿到。也许是的,小公司或者非互联网企业拿两万的不太可能是码农了,应该是已经转管理后才有可能。还有区域问题,这个不在我的考虑范围内,因为除了北上广深杭,其他地方也很难。还有人提到这个水平不止2w,其...

spring boot 整合 activeMQ之ERROR 3432 --- [-netty-threads)] org.apache.activemq.artemis.core.client : AMQ214013: Failed to decode packet

笔者在做spring boot 整合 activeMQ时,报以下错,记录一下,:ERROR 3432 --- [-netty-threads)] org.apache.activemq.artemis.core.client  : AMQ214013: Failed to decode p...

Java工具类对接百度熊掌号API推送接口进行文章推送实例

目前,百度推出了百度熊掌号服务。旨在更好的为站长服务。那么百度熊掌号如何通过推送API接口实现自动文章推送呢?第一步:注册百度熊掌号,获取推送链接appid以及token第二步:用java代码实现的推送,代码如下:import java.net.URI; import java.util.Arra...

FreeMarker工具类、FreeMarker与Spring集成工具类用法优缺点

一、原生的freemarker工具类。缺点:无法使用集成在spring容器里的一些插件,代码如下:/** * * free模板工具 * @author everycoding.com */ public class FreeMarkerUtils { private s...

Springboot配置属性之spring前缀配置详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean ,为一个不生效的组件设置属性是没有用的。以下是如何集成例如MQ、artemis、Cache、DataSource、FreeMarker等多个plugin配置。工作线...

Springboot配置属性之server详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean ,为一个不生效的组件设置属性是没有用的。server.address 服务器绑定的网络地址。 server.compression.enabled 是否要开启...

Springboot配置属性之security详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean ,为一个不生效的组件设置属性是没有用的。security.basic.authorize-mode 要运用的安全授权模式。 security.basic.ena...

Springboot配置属性之multipart详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean ,为一个不生效的组件设置属性是没有用的。multipart.enabled 开启分段(multi-part)上传支持。 (默认值: true 。 )mul...

Springboot配置属性之liquibase详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean ,为一个不生效的组件设置属性是没有用的。liquibase.change-log变更日志配置路径。 (默认值: classpath:/db/changelog/db...

Springboot配置属性之flyway详解

Spring Boot组件提供的全部配置属性。请注意,这些属性是否生效取决于对应的组件是否声明为Spring应用程序上下文里的Bean(基本是自动配置的) ,为一个不生效的组件设置属性是没有用的。flyway.baseline-description执行基线时标记已有Schema的描述。flyway...

Spring Boot Admin的简单使用实例

创建一个项目,用于展示各个服务中的监控信息,加上Spring Boot Admin的依赖:dependency> <groupId>de.codecentric</groupId> <artifactId>spring-boot-admi...

熔断机制应用之Hystrix配置信息

在Hystrix中我们一般是用的默认配置,有些时候需要调整一些参数来获取更好的处理性能配置官方文档:https://github.com/Netflix/Hystrix/wiki/ConfigurationExecution相关的属性的配置:hystrix.command.default.execu...

SpringBoot 如何整合Kafka的使用详解

前提假设你了解过 SpringBoot 和 Kafka。1、SpringBoot如果对 SpringBoot 不了解的话,建议去看看 DD 大佬 和 纯洁的微笑 的系列博客。2、KafkaKafka 的话可以看看我前两天写的博客 : Kafka 安装及快速入门   学习的话自己开台虚拟机自...

Java系统过载保护机制之信号量的控制

在高并发、大流量的访问系统时,如果不采取适当的系统过载保护策略,可能会导致系统崩溃。那么,系统过载保护有哪些呢?通常有:漏桶算法,例如Google Guava信号量控制,例如jdk原生自带的Semaphore 通过这些算法,可有效过滤过量的请求量,阻挡一部分请求流量,来保证大部分人群能继续使用系统。...