标签:producer

Spring

看spring cloud开源项目Pig的云踩坑记

9

changyuan.xu 发布于 2018-12-12

最近看到一个有趣的开源项目pig,主要的技术点在认证授权中心,spring security oauth,zuul网关实现,Elastic-Job定时任务,趁着刚刚入门微服务,赶快写个博客分析一下。此篇文章主要用于个人备忘。如果有不对,请批评。:sob: 由于每个模块篇幅较长,且...

阅读(34)评论(0)赞 (0)

编程技术

随行付微服务测试之接口测试和契约测试 原 荐

8

dulong 发布于 2018-12-11

背景 日常开发过程中,项目的接口通常由服务提供方约定和提供,微服务模式下接口被多个消费者调用更是常态,那么提供方接口的变更如何快速、高效、无遗漏的通知给消费者呢?另外,当一个service同时被多个使用者调用,如何保证对service的修改可以让其它所有使用者造成的影响都能被感知...

阅读(21)评论(0)赞 (0)

Java

Spring Cloud Stream消费失败后的处理策略(一):自动重试

Harries 发布于 2018-12-10

之前写了几篇关于Spring Cloud Stream使用中的常见问题,比如: 如何处理消息重复消费 如何消费自己生产的消息 下面几天就集中来详细聊聊,当消息消费失败之后该如何处理的几种方式。不过不论哪种方式,都需要与具体业务结合,解决不同业务场景可能出现的问题。 今天第一节,介...

阅读(38)评论(0)赞 (0)

Java

LockSupport中的park与unpark原理

2

puefu.he 发布于 2018-12-03

LockSupport是用来创建locks的基本线程阻塞基元,比如AQS中实现线程挂起的方法,就是park,对应唤醒就是unpark。JDK中有使用的如下 LockSupport提供的是一个许可,如果存在许可,线程在调用 park 的时候,会立马返回,此时许可也会被消费掉,如果没...

阅读(27)评论(0)赞 (0)

Spring

Spring Boot和Kafka实战自定义复杂配置示例

1

yeseng 发布于 2018-11-28

这篇博客文章展示了如何配置Spring Kafka和Spring Boot以使用JSON发送消息并以多种格式接收它们:JSON,纯字符串或字节数组。基于此配置,您还可以将Kafka生成器从发送JSON切换到其他序列化方法。 此示例应用程序还演示了同一消费组中三个Kafka消费者的...

阅读(45)评论(0)赞 (0)

Java

调试 Flink 源码

11

刘莉莉 发布于 2018-11-24

本文主要是讲讲flink的源码编译,案例运行,flink源码调试过程。调试flink的源码及案例,需要先clone工程,编一下源码,去掉规范检查,修改工程,最后才是调试运行。 1. clone工程 首先复制flink的github地址 git@github.com:apache/...

阅读(50)评论(0)赞 (0)

Java

RocketMQ at a glance

yanxinchi 发布于 2018-11-22

64位操作系统,建议使用Linux / Unix / CentOs 7.3 + 64bit JDK 1.8 + Maven 3.2.x + 1.2 Download & Build from Release Click here to download the 4.3.0...

阅读(47)评论(0)赞 (0)

Java

Apache Qpid JMS 0.38.0,Java Message Service 客户端

zhuangli 发布于 2018-11-20

Apache Qpid JMS 0.38.0 发布了,Qpid JMS 是一个使用了 Qpid Proton 协议引擎完整的 Java Message Service 2.0 客户端。支持基于 Apache Qpid Proton 协议引擎的高级消息队列协议 1.0(AMQP 1...

阅读(59)评论(0)赞 (0)

Java

在Java Stream实现大型查询

xirruiqiang 发布于 2018-11-18

Spring JdbcTemplate从1.0版开始就一直在使用这个类,并且它的发展很好,但我希望在版本5中它会包含一些流式处理功能,用于查询很大数据结果,可惜没有发生。 尽管如此,有时我需要执行返回数百万行的查询,而且我不能使用JdbcTemplate方法来返回列表,RowCa...

阅读(40)评论(0)赞 (0)

Java

Netty NioEventLoop 创建过程源码分析

5

likai 发布于 2018-11-09

原文: wangwei.one/posts/netty… 前面 ,我们分析了Netty中的Channel组件,本篇我们来介绍一下与Channel关联的另一个核心的组件 —— EventLoop 。 Netty版本:4.1.30 概述 EventLoop定义了Netty的核心抽象,...

阅读(49)评论(0)赞 (0)

Java

ActiveMQ学习-与spring整合,在spring-boot中使用 (5)

1

puefu.he 发布于 2018-11-09

在spring-boot中使用ActiveMQ相当的简单 引入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-s...

阅读(46)评论(0)赞 (0)

Java

ActiveMQ学习-Api介绍 (4)

1

puefu.he 发布于 2018-11-08

Session 第一节提到了消息提供者在创建session的时候第一个参数是事务的意思,如果将其改成 true ,那么当发送完消息后就要 commit() 一下,消息才能发出 public class Producer { public static void main(Stri...

阅读(56)评论(0)赞 (0)

Java

ActiveMQ学习-持久化队列数据,将队列中的消息存入MySQL (3)

3

yanxinchi 发布于 2018-11-06

ActiveMQ默认使用的持久性机制是KahaDB,这货不熟悉,所以这篇文章来介绍一下将队列中的消息存放在MySQL数据库里 修改配置 找到 conf 文件夹,打开 activemq.xml 文件,找到下面配置 <persistenceAdapter> <kah...

阅读(73)评论(0)赞 (0)

Java

ActiveMQ学习-HelloWorld

likai 发布于 2018-11-05

安装ActiveMQ ActiveMQ官网 下载ActiveMQ 解压,进入 bin 运行 cd [activemq_install_dir]/bin ./activemq console 我用的是MAC,还可以使用homebrew安装, 我这里用的是 5.15.7 版本 bre...

阅读(47)评论(0)赞 (0)

Spring

如何在Spring Boot应用程序中使用Apache Kafka?

尖兵 发布于 2018-11-02

第1步:生成我们的项目: Spring Initializr 来生成我们的项目。我们的项目将提供Spring MVC / Web支持和Apache Kafka支持。 第2步:发布/读取Kafka主题中的消息: <b>public</b> <b>...

阅读(44)评论(0)赞 (0)

Java

Java开发规约

xiaoli.wang 发布于 2018-11-01

消防局最主要的工作不是灭火,而是防患于未然,做好安全保障工作。 前车之鉴,后车之师 ,从开发的视角,结合正反例分析,避免在同一块石头上跌倒多次。 好规约有利于提高程序的可读性、可维护性、可复用性,提高软件质量。 众所周知,制订交通法规表面上是要限制行车权,实际上是保障公众的人身安...

阅读(74)评论(0)赞 (0)

Spring

jetty、servlet以及spring的衔接源码分析

1

小丁 发布于 2018-10-25

对于一个请求来讲,如果只是需要一个静态页面,可以直接在服务器上根据路径访问得到,但是如果请求的数据是一个动态页面,即只有在运行时从后台数据库获取,再拼装东西返回,然后生成一个对应的html文件。在Java中为了实现这个功能,使用的就是Servlet规范。 Servlet:serv...

阅读(51)评论(0)赞 (0)