【转】浅谈服务治理与微服务

2019年6月21日 | Leave a comment

https://www.cnblogs.com/scode2/p/8820155.html 近期… Read More

private static enum StoreFieldSetMapper implements FieldSetMapper 这种写法少见呢

2019年6月19日 | Leave a comment

/*
 * Copyright 2014 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package example.stores;

import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

import lombok.extern.slf4j.Slf4j;

import org.springframework.batch.item.ExecutionContext;
import org.springframework.batch.item.file.FlatFileItemReader;
import org.springframework.batch.item.file.mapping.DefaultLineMapper;
import org.springframework.batch.item.file.mapping.FieldSetMapper;
import org.springframework.batch.item.file.separator.DefaultRecordSeparatorPolicy;
import org.springframework.batch.item.file.transform.DelimitedLineTokenizer;
import org.springframework.batch.item.file.transform.FieldSet;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.ClassPathResource;
import org.springframework.data.geo.Point;
import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.stereotype.Component;
import org.springframework.validation.BindException;

/**
 * Component initializing a hand full of Starbucks stores and persisting them through a {@link StoreRepository}.
 * 
 * @author Oliver Gierke
 */
@Slf4j
@Component
public class StoreInitializer {

	@Autowired
	public StoreInitializer(StoreRepository repository) throws Exception {

		if (repository.count() != 0) {
			return;
		}

		List<Store> stores = readStores();
		log.info("Importing {} stores into MongoDB…", stores.size());
		repository.saveAll(stores);
		log.info("Successfully imported {} stores.", repository.count());
	}

	/**
	 * Reads a file {@code starbucks.csv} from the class path and parses it into {@link Store} instances about to
	 * persisted.
	 * 
	 * @return
	 * @throws Exception
	 */
	public static List<Store> readStores() throws Exception {

		ClassPathResource resource = new ClassPathResource("starbucks.csv");
		Scanner scanner = new Scanner(resource.getInputStream());
		String line = scanner.nextLine();
		scanner.close();

		FlatFileItemReader<Store> itemReader = new FlatFileItemReader<Store>();
		itemReader.setResource(resource);

		// DelimitedLineTokenizer defaults to comma as its delimiter
		DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer();
		tokenizer.setNames(line.split(","));
		tokenizer.setStrict(false);

		DefaultLineMapper<Store> lineMapper = new DefaultLineMapper<Store>();
		lineMapper.setLineTokenizer(tokenizer);
		lineMapper.setFieldSetMapper(StoreFieldSetMapper.INSTANCE);
		itemReader.setLineMapper(lineMapper);
		itemReader.setRecordSeparatorPolicy(new DefaultRecordSeparatorPolicy());
		itemReader.setLinesToSkip(1);
		itemReader.open(new ExecutionContext());

		List<Store> stores = new ArrayList<>();
		Store store = null;

		do {

			store = itemReader.read();

			if (store != null) {
				stores.add(store);
			}

		} while (store != null);

		return stores;
	}

	private static enum StoreFieldSetMapper implements FieldSetMapper<Store> {

		INSTANCE;

		/* 
		 * (non-Javadoc)
		 * @see org.springframework.batch.item.file.mapping.FieldSetMapper#mapFieldSet(org.springframework.batch.item.file.transform.FieldSet)
		 */
		@Override
		public Store mapFieldSet(FieldSet fields) throws BindException {

			Point location = new Point(fields.readDouble("Longitude"), fields.readDouble("Latitude"));
			Address address = new Address(fields.readString("Street Address"), fields.readString("City"),
					fields.readString("Zip"), location);

			return new Store(fields.readString("Name"), address);
		}
	}
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

* Licensed under the Apache License, Version 2.0 (the "License");

* you may not use this file except in compliance with the License.

* You may obtain a copy of the License at

* http://www.apache.org/licenses/LICENSE-2.0

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

package example.stores;

import java.util.ArrayList;

import java.util.List;

import java.util.Scanner;

import lombok.extern.slf4j.Slf4j;

import org.springframework.batch.item.ExecutionContext;

import org.springframework.batch.item.file.FlatFileItemReader;

import org.springframework.batch.item.file.mapping.DefaultLineMapper;

import org.springframework.batch.item.file.mapping.FieldSetMapper;

import org.springframework.batch.item.file.separator.DefaultRecordSeparatorPolicy;

import org.springframework.batch.item.file.transform.DelimitedLineTokenizer;

import org.springframework.batch.item.file.transform.FieldSet;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.core.io.ClassPathResource;

import org.springframework.data.geo.Point;

import org.springframework.data.mongodb.core.MongoOperations;

import org.springframework.stereotype.Component;

import org.springframework.validation.BindException;

/**

* Component initializing a hand full of Starbucks stores and persisting them through a {@link StoreRepository}.

* @author Oliver Gierke

@Slf4j

@Component

public class StoreInitializer {

@Autowired

public StoreInitializer(StoreRepository repository) throws Exception {

if (repository.count() != 0) {

return;

}

List<Store> stores = readStores();

log.info("Importing {} stores into MongoDB…", stores.size());

repository.saveAll(stores);

log.info("Successfully imported {} stores.", repository.count());

}

/**

* Reads a file {@code starbucks.csv} from the class path and parses it into {@link Store} instances about to

* persisted.

* @return

* @throws Exception

public static List<Store> readStores() throws Exception {

ClassPathResource resource = new ClassPathResource("starbucks.csv");

Scanner scanner = new Scanner(resource.getInputStream());

String line = scanner.nextLine();

scanner.close();

FlatFileItemReader<Store> itemReader = new FlatFileItemReader<Store>();

itemReader.setResource(resource);

// DelimitedLineTokenizer defaults to comma as its delimiter

DelimitedLineTokenizer tokenizer = new DelimitedLineTokenizer();

tokenizer.setNames(line.split(","));

tokenizer.setStrict(false);

DefaultLineMapper<Store> lineMapper = new DefaultLineMapper<Store>();

lineMapper.setLineTokenizer(tokenizer);

lineMapper.setFieldSetMapper(StoreFieldSetMapper.INSTANCE);

itemReader.setLineMapper(lineMapper);

itemReader.setRecordSeparatorPolicy(new DefaultRecordSeparatorPolicy());

itemReader.setLinesToSkip(1);

itemReader.open(new ExecutionContext());

List<Store> stores = new ArrayList<>();

Store store = null;

do {

store = itemReader.read();

if (store != null) {

stores.add(store);

}

} while (store != null);

return stores;

}

private static enum StoreFieldSetMapper implements FieldSetMapper<Store> {

INSTANCE;

* (non-Javadoc)

* @see org.springframework.batch.item.file.mapping.FieldSetMapper#mapFieldSet(org.springframework.batch.item.file.transform.FieldSet)

@Override

public Store mapFieldSet(FieldSet fields) throws BindException {

Point location = new Point(fields.readDouble("Longitude"), fields.readDouble("Latitude"));

Address address = new Address(fields.readString("Street Address"), fields.readString("City"),

fields.readString("Zip"), location);

return new Store(fields.readString("Name"), address);

}

&… Read More

【未解决】springboot bean init-method 不灵光呢

2019年6月14日 | Leave a comment

问题：下列代码不会调用 init 方法

@Component
//@RequestScope
@Scope(scopeName = "prototype", proxyMode = ScopedProxyMode.TARGET_CLASS)
public class RequestOpContext implements InitializingBean {
    int i = 0;
    public RequestOpContext(){
        System.out.println("RequestOpContext()");
    }

    public void init(){
        System.out.println("init");
        i=10;
    }

    public int getId(){
        return i;
    }

    @Override
    public void afterPropertiesSet() throws Exception {
        init();
    }
}

@Component

//@RequestScope

@Scope(scopeName = "prototype", proxyMode = ScopedProxyMode.TARGET_CLASS)

public class RequestOpContext implements InitializingBean {

int i = 0;

public RequestOpContext(){

System.out.println("RequestOpContext()");

}

public void init(){

System.out.println("init");

i=10;

}

public int getId(){

return i;

}

@Override

public void afterPropertiesSet() throws Exception {

init();

}

&… Read More

【转】解决sourceforge下载速度慢畅快下载sourceforge开源软件

2019年6月11日 | Leave a comment

https://chaihongjun.me/others/190.html &n… Read More

IDEA spring boot devtools 怎么使用

2019年6月6日 | Leave a comment

问题： IDEA devtools 不起作用了，改了类不会自动重新运行解决： C… Read More

【转】Spring Boot Hot Switch Configuration under Intellij IDEA

2019年6月6日 | Leave a comment

Spring Boot Hot Switch Configuration under Intellij IDE… Read More

【转】Fortran, Matlab, Octave, Scilab计算速度比较

2019年6月5日 | Leave a comment

https://blog.csdn.net/ztguang/article/details/51913255 … Read More

【转】5款替代微软Visio的开源免费软件

2019年6月4日 | Leave a comment

https://www.cnblogs.com/liangxiaofeng/p/6508942.html &n… Read More

【转】gradle配置国内镜像

2019年5月31日 | Leave a comment

https://www.cnblogs.com/a8457013/p/8408196.html … Read More

macbook pro caps lock 失灵

2019年5月26日 | Leave a comment

问题：解决：系统偏好设置-》输入法-〉取消勾选“使用大小写键盘锁定”… Read More

IT问题

程序员的疑难杂症录