paulwong

#

Spring integration 基本概念

1.spring integration 's architecture

主要提供两个功能：

在系统内提供实现轻量级、事件驱动交互行为的框架

在系统间提供一种基于适配器的平台，以支持灵活的系统间交互

2.spring integration对于企业集成模式的支持

2.1Message：一个信息的单元，通常有消息头（header）和消息内容（payload）组成

2.2Message channel：消息处理节点之间的连接，负责将Message从生产者传输到消费者。

    根据消费者的多少，可分为point to point和publish-subscribe两种


    根据消息传输方式的不同，分为同步和异步两种

2.3Message Endpoint：消息处理节点，消息从节点进入通道，也是从节点离开通道

几个常见的Message EndPoint：

CHANNEL ADAPTER，用于连接该适配器的特点是单向消息流的，要么是消息通过该适配器进入通道，要么是消息通过该适配器离开通道


MESSAGING GATEWAY，处理的消息流和Channel Adapter不同，不是单向的，即有进入该节点的消息，也会从该节点发出消息。



SERVICE ACTIVATOR，该节点调用服务来处理输入的消息，并将服务返回的数据发送到输出通道。在spring integration中，调用的方法被限定为本地方法调用。


ROUTER，路由器，将输入的消息路由到某个输出通道中


SPLITTER，将输入的消息拆分成子消息


AGGREGATOR，将输入的多个消息合并为一个消息


3.观看书中例子hello-world思考

测试gateway时，下面代码向通道names内放入消息world？


然后service-activator从names通道中获得消息world，调用方法sayHello返回值到给gateway？

解释：gateway有一个service－interface的属性，这个属性指向一个interface。当我们用一个接口声明一个gateway时，spring integration会自动帮我们生成该接口的代理类，这样当我们往gateway发送消息时，spring integration会通过代理类把消息转发到default－request－channel中去



作者：马国标
链接：https://www.jianshu.com/p/bf1643539f99
来源：简书
简书著作权归作者所有，任何形式的转载都请联系作者获得授权并注明出处。

posted @ 2019-06-05 10:36 paulwong 阅读(882) | 评论 (0) | 编辑 收藏

如何在SPRING INTEGRATION中使用事务

File Polling using the Spring Integration DSL
http://porterhead.blogspot.com/2016/07/file-polling-using-spring-integration.html

https://github.com/iainporter/spring-file-poller


Transaction Support in Spring Integration
https://www.baeldung.com/spring-integration-transaction

posted @ 2019-06-04 14:19 paulwong 阅读(428) | 评论 (0) | 编辑 收藏

SpringBoot使用MongoDB异常问题

https://www.cnblogs.com/linzhanfly/p/9674778.html

posted @ 2019-05-29 16:58 paulwong 阅读(428) | 评论 (0) | 编辑 收藏

MONGODB去除_class字段

加上此配置：

MongodbConfiguration.java
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.core.convert.DbRefResolver;
import org.springframework.data.mongodb.core.convert.DefaultDbRefResolver;
import org.springframework.data.mongodb.core.convert.DefaultMongoTypeMapper;
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
import org.springframework.data.mongodb.core.mapping.MongoMappingContext;
 
@Configuration
public class AppMongoConfig {
  @Autowired private MongoDbFactory mongoDbFactory;
 
  @Autowired private MongoMappingContext mongoMappingContext;
 
  @Bean
  public MappingMongoConverter mappingMongoConverter() {
 
    DbRefResolver dbRefResolver = new DefaultDbRefResolver(mongoDbFactory);
    MappingMongoConverter converter = new MappingMongoConverter(dbRefResolver, mongoMappingContext);
    converter.setTypeMapper(new DefaultMongoTypeMapper(null));
 
    return converter;
  }
}

posted @ 2019-05-29 14:18 paulwong 阅读(1209) | 评论 (0) | 编辑 收藏

JAVA 8 TIME

Java 8新特性（四）：新的时间和日期API
https://lw900925.github.io/java/java8-newtime-api.html
 

posted @ 2019-05-09 10:15 paulwong 阅读(351) | 评论 (0) | 编辑 收藏

SPRING BOOT BATCH资源

 Spring Boot下Spring Batch入门实例
https://www.jianshu.com/p/305192ea4cb1
 

SPRING BATCH + QUARTZ
https://examples.javacodegeeks.com/enterprise-java/spring/batch/quartz-spring-batch-example/
https://blog.kingbbode.com/posts/spring-batch-quartz

Spring Batch Tutorial: Batch Processing Made Easy with Spring
https://www.toptal.com/spring/spring-batch-tutorial

posted @ 2019-05-07 17:07 paulwong 阅读(366) | 评论 (0) | 编辑 收藏

以流的方式解释巨大JSON文件

https://www.ngdata.com/parsing-a-large-json-file-efficiently-and-easily/


https://sites.google.com/site/gson/streaming

http://www.acuriousanimal.com/2015/10/23/reading-json-file-in-stream-mode-with-gson.html

    public static void main(String [] args) throws IOException {
        String filePath = "C:big-data.json";
        FileInputStream in = new FileInputStream(new File(filePath));
        JsonReader reader = new JsonReader(new InputStreamReader(in, "UTF-8"));
        Gson gson = new GsonBuilder().create();
//        reader.beginObject();
//        reader.nextName();
        reader.beginObject();//跳过"{"
        while (reader.hasNext()) {
            // Read data into object model
            JsonToken jsonToken = reader.peek();
            if(jsonToken.equals(JsonToken.NAME)) {
                String name = reader.nextName();
                if(name.equalsIgnoreCase("SUMMARY")) {
//                    reader.beginObject();
                    Summary summary = gson.fromJson(reader, Summary.class);
                    logger.info(summary.toString());
                    break;
//                    reader.endObject();//跳过"}"
                }
            } /*else if(jsonToken.equals(JsonToken.BEGIN_OBJECT)) {
                reader.beginObject();
            } else if(jsonToken.equals(JsonToken.STRING)) {
                logger.info(reader.nextString());
            } else if(jsonToken.equals(JsonToken.NUMBER)) {
                logger.info(reader.nextInt() + "");
            } else if(jsonToken.equals(JsonToken.END_OBJECT)) {
                reader.endObject();
            } */
//            Summary summary = gson.fromJson(reader, Summary.class);
//            break;
        }
        reader.close();
    }

posted @ 2019-05-03 15:22 paulwong 阅读(518) | 评论 (0) | 编辑 收藏

定时任务管理系统资源

SpringBoot 整合 Quartz 实现定时任务管理模块
https://juejin.im/post/5a7157f56fb9a01cb049a158

posted @ 2019-04-25 17:03 paulwong 阅读(352) | 评论 (0) | 编辑 收藏

2018预测

https://www.oschina.net/news/91924/10-open-source-technology-trends-2018 http://www.iteye.com/news/32843

posted @ 2018-01-15 10:51 paulwong 阅读(602) | 评论 (0) | 编辑 收藏

JAX-RS2资源

JAX-RS 2比JAX-RS 1增加了过滤器、拦截器、异步处理等特性。@import url(http://www.blogjava.net/CuteSoft_Client/CuteEditor/Load.ashx?type=style&file=SyntaxHighlighter.css);@import url(/css/cuteeditor.css);

JAXRSClientSpringBoot
http://cxf.apache.org/docs/jaxrsclientspringboot.html

CXFSpringBoot
http://cxf.apache.org/docs/springboot.html

Restfull Webservice书源码
https://github.com/feuyeux

JAX-RS 2.0 REST客户端编程实例
http://www.importnew.com/8939.html

本人的DEMO
https://git.oschina.net/paulwong/test-cxf

posted @ 2017-09-24 17:19 paulwong 阅读(1182) | 评论 (0) | 编辑 收藏

仅列出标题
共112页: First 上一页 23 24 25 26 27 28 29 30 31 下一页 Last