yaml复制代码spring:
   servlet:
     multipart:
       max-file-size: 10MB
       max-request-size: 100MB

less复制代码package com.jf3q.study.control;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.multipart.MultipartFile;

import java.io.File;
import java.io.IOException;

@Controller
@Slf4j
public class RegControl {

    @GetMapping("/toreg")
    public  String toreg(){
        return "register";
    }


    /**
     *
     * 平时遇到自己解决不了的bug问题可以来编程问答平台悬赏问答，
     * 解决不了不要钱，地址：https://www.jf3q.com/
     * @param username
     * @param password
     * @param faceImg
     * @param lifeimg
     * @return
     */
    @PostMapping("/reg")
    public String reg( @RequestParam("username") String username,
                       @RequestParam("username") String password,
                       @RequestParam("faceImg") MultipartFile faceImg,
                       @RequestParam("lifeimg") MultipartFile[] lifeimg ) throws IOException {

        log.info("username:{},password:{},faceImg:{},lifeimg：{}",username,password,faceImg.getSize(),lifeimg.length);

        if(!faceImg.isEmpty()){
            String originalFilename = faceImg.getOriginalFilename();//获取上传文件的名字
            faceImg.transferTo(new File("E:\\upload\\"+originalFilename));
        }
        if(lifeimg.length > 0){
            for(MultipartFile img :lifeimg){
                if(!img.isEmpty()){
                    String originalFilename = img.getOriginalFilename();//获取上传文件的名字
                    img.transferTo(new File("E:\\upload\\"+originalFilename));
                }

            }
        }


        return "login";
    }
}

typescript复制代码@Override
public void addInterceptors(InterceptorRegistry registry) {
    registry.addInterceptor(new LoginInterceptor())
            .addPathPatterns("/**") //所有请求都被拦截，包括静态资源
            .excludePathPatterns("/","/login","/toreg","/reg","/img/**","/js/**","/css/**","/favicon.ico");//设置不拦截的路径
}

xml复制代码<!-- SpringRetry -->
<dependency>
	  <groupId>org.springframework.retry</groupId>
	  <artifactId>spring-retry</artifactId>
</dependency>
<dependency>
	  <groupId>org.springframework</groupId>
	  <artifactId>spring-aspects</artifactId>
</dependency>

java复制代码package org.springframework.retry;

public interface RetryListener {

	/**
	 * 任务开始执行时调用，只调用一次
	 */
	<T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback);

	/**
	 * 任务执行结束时(包含重试)调用，只调用一次
	 */
	<T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable);

	/**
	 * 出现错误时回调
	 */
	<T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable);
}

java复制代码FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();
fixedBackOffPolicy.setBackOffPeriod(1000L);
retryTemplate.setBackOffPolicy(fixedBackOffPolicy);

java复制代码// 指数回退(秒)，第一次回退1s，第二次回退2s，第三次4秒，第四次8秒
ExponentialBackOffPolicy exponentialBackOffPolicy = new ExponentialBackOffPolicy();
exponentialBackOffPolicy.setInitialInterval(1000L);
exponentialBackOffPolicy.setMultiplier(2);
retryTemplate.setBackOffPolicy(exponentialBackOffPolicy);

java复制代码// 重试策略
SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
retryPolicy.setMaxAttempts(5);
retryTemplate.setRetryPolicy(retryPolicy);

java复制代码import com.codecoord.util.PrintUtil;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.retry.RetryCallback;
import org.springframework.retry.RetryContext;
import org.springframework.retry.RetryListener;
import org.springframework.retry.backoff.ExponentialBackOffPolicy;
import org.springframework.retry.policy.SimpleRetryPolicy;
import org.springframework.retry.support.RetryTemplate;

@Configuration
public class RetryTemplateConfig {

    /**
     * 注入retryTemplate
     */
    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate retryTemplate = new RetryTemplate();

        /// 回退固定时间(秒)
       /* FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();
        fixedBackOffPolicy.setBackOffPeriod(1000L);
        retryTemplate.setBackOffPolicy(fixedBackOffPolicy);*/

        // 指数回退(秒)，第一次回退1s，第二次回退2s
        ExponentialBackOffPolicy exponentialBackOffPolicy = new ExponentialBackOffPolicy();
        exponentialBackOffPolicy.setInitialInterval(1000L);
        exponentialBackOffPolicy.setMultiplier(2);
        retryTemplate.setBackOffPolicy(exponentialBackOffPolicy);

        // 重试策略
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(5);
        retryTemplate.setRetryPolicy(retryPolicy);

        // 设置监听器，open和close分别在启动和结束时执行一次
        RetryListener[] listeners = {
                new RetryListener() {
                    @Override
                    public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
                        PrintUtil.print("open");
                        return true;
                    }
                    @Override
                    public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback,
                            Throwable throwable) {
                        PrintUtil.print("close");
                    }
                    @Override
                    public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback,
                            Throwable throwable) {
                        PrintUtil.print("onError");
                    }
                }
        };
        retryTemplate.setListeners(listeners);

        return retryTemplate;
    }
}

java复制代码@RestController
public class SpringRetryController {
    @Resource
    private RetryTemplate retryTemplate;
    private static int count = 0;

    @RequestMapping("/retry")
    public Object retry() {
        try {
            count = 0;
            retryTemplate.execute((RetryCallback<Void, RuntimeException>) context -> {
                // 业务代码
                // ....
                // 模拟抛出异常
                ++count;
                throw new RuntimeException("抛出异常");
            });
        } catch (RuntimeException e) {
            System.out.println("Exception");
        }

        return "retry = " + count;
    }
}

java复制代码18:27:20.648 - http-nio-8888-exec-1 - open
18:27:20.649 - http-nio-8888-exec-1 - retryTemplate.execute执行
18:27:20.649 - http-nio-8888-exec-1 - onError
18:27:21.658 - http-nio-8888-exec-1 - retryTemplate.execute执行
18:27:21.658 - http-nio-8888-exec-1 - onError
18:27:23.670 - http-nio-8888-exec-1 - retryTemplate.execute执行
18:27:23.670 - http-nio-8888-exec-1 - onError
18:27:27.679 - http-nio-8888-exec-1 - retryTemplate.execute执行
18:27:27.679 - http-nio-8888-exec-1 - onError
18:27:35.681 - http-nio-8888-exec-1 - retryTemplate.execute执行
18:27:35.681 - http-nio-8888-exec-1 - onError
18:27:35.681 - http-nio-8888-exec-1 - close

java复制代码import org.springframework.retry.annotation.Retryable;

public interface RetryService {

    /**
     * 重试方法调用
     */
    @Retryable
    void retryServiceCall();
}

java复制代码import org.springframework.retry.annotation.EnableRetry;
import org.springframework.stereotype.Service;

@EnableRetry
@Service
public class RetryServiceImpl implements RetryService {

    @Override
    public void retryServiceCall() {
        PrintUtil.print("方法调用..");
        throw new RuntimeException("手工异常");
    }
}

java复制代码@RequestMapping("/retryAnnotation")
public Object retryAnnotation() {
    retryService.retryServiceCall();
    return "retryAnnotation";
}

java复制代码18:46:48.721 - http-nio-8888-exec-1 - 方法调用..
18:46:49.724 - http-nio-8888-exec-1 - 方法调用..
18:46:50.730 - http-nio-8888-exec-1 - 方法调用..
java.lang.RuntimeException: 手工异常

java复制代码@Target({ ElementType.METHOD, ElementType.TYPE })
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Retryable {

	/**
	 * Retry interceptor bean name to be applied for retryable method. Is mutually
	 * exclusive with other attributes.
	 * @return the retry interceptor bean name
	 */
	String interceptor() default "";

	/**
	 * Exception types that are retryable. Synonym for includes(). Defaults to empty (and
	 * if excludes is also empty all exceptions are retried).
	 * @return exception types to retry
	 */
	Class<? extends Throwable>[] value() default {};

	/**
	 * Exception types that are retryable. Defaults to empty (and if excludes is also
	 * empty all exceptions are retried).
	 * @return exception types to retry
	 */
	Class<? extends Throwable>[] include() default {};

	/**
	 * Exception types that are not retryable. Defaults to empty (and if includes is also
	 * empty all exceptions are retried).
	 * If includes is empty but excludes is not, all not excluded exceptions are retried
	 * @return exception types not to retry
	 */
	Class<? extends Throwable>[] exclude() default {};

	/**
	 * A unique label for statistics reporting. If not provided the caller may choose to
	 * ignore it, or provide a default.
	 *
	 * @return the label for the statistics
	 */
	String label() default "";

	/**
	 * Flag to say that the retry is stateful: i.e. exceptions are re-thrown, but the
	 * retry policy is applied with the same policy to subsequent invocations with the
	 * same arguments. If false then retryable exceptions are not re-thrown.
	 * @return true if retry is stateful, default false
	 */
	boolean stateful() default false;

	/**
	 * @return the maximum number of attempts (including the first failure), defaults to 3
	 */
	int maxAttempts() default 3;

	/**
	 * @return an expression evaluated to the maximum number of attempts (including the first failure), defaults to 3
	 * Overrides {@link #maxAttempts()}.
	 * @date 1.2
	 */
	String maxAttemptsExpression() default "";

	/**
	 * Specify the backoff properties for retrying this operation. The default is a
	 * simple {@link Backoff} specification with no properties - see it's documentation
	 * for defaults.
	 * @return a backoff specification
	 */
	Backoff backoff() default @Backoff();

	/**
	 * Specify an expression to be evaluated after the {@code SimpleRetryPolicy.canRetry()}
	 * returns true - can be used to conditionally suppress the retry. Only invoked after
	 * an exception is thrown. The root object for the evaluation is the last {@code Throwable}.
	 * Other beans in the context can be referenced.
	 * For example:
	 * <pre class=code>
	 *  {@code "message.contains('you can retry this')"}.
	 * </pre>
	 * and
	 * <pre class=code>
	 *  {@code "@someBean.shouldRetry(#root)"}.
	 * </pre>
	 * @return the expression.
	 * @date 1.2
	 */
	String exceptionExpression() default "";

	/**
	 * Bean names of retry listeners to use instead of default ones defined in Spring context
	 * @return retry listeners bean names
	 */
	String[] listeners() default {};

}

java复制代码@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Backoff {

	/**
	 * Synonym for {@link #delay()}.
	 *
	 * @return the delay in milliseconds (default 1000)
	 */
	long value() default 1000;

	/**
	 * A canonical backoff period. Used as an initial value in the exponential case, and
	 * as a minimum value in the uniform case.
	 * @return the initial or canonical backoff period in milliseconds (default 1000)
	 */
	long delay() default 0;

	/**
	 * The maximimum wait (in milliseconds) between retries. If less than the
	 * {@link #delay()} then the default of
	 * {@value org.springframework.retry.backoff.ExponentialBackOffPolicy#DEFAULT_MAX_INTERVAL}
	 * is applied.
	 *
	 * @return the maximum delay between retries (default 0 = ignored)
	 */
	long maxDelay() default 0;

	/**
	 * If positive, then used as a multiplier for generating the next delay for backoff.
	 *
	 * @return a multiplier to use to calculate the next backoff delay (default 0 =
	 * ignored)
	 */
	double multiplier() default 0;

	/**
	 * An expression evaluating to the canonical backoff period. Used as an initial value
	 * in the exponential case, and as a minimum value in the uniform case. Overrides
	 * {@link #delay()}.
	 * @return the initial or canonical backoff period in milliseconds.
	 * @date 1.2
	 */
	String delayExpression() default "";

	/**
	 * An expression evaluating to the maximimum wait (in milliseconds) between retries.
	 * If less than the {@link #delay()} then the default of
	 * {@value org.springframework.retry.backoff.ExponentialBackOffPolicy#DEFAULT_MAX_INTERVAL}
	 * is applied. Overrides {@link #maxDelay()}
	 *
	 * @return the maximum delay between retries (default 0 = ignored)
	 * @date 1.2
	 */
	String maxDelayExpression() default "";

	/**
	 * Evaluates to a vaule used as a multiplier for generating the next delay for
	 * backoff. Overrides {@link #multiplier()}.
	 *
	 * @return a multiplier expression to use to calculate the next backoff delay (default
	 * 0 = ignored)
	 * @date 1.2
	 */
	String multiplierExpression() default "";

	/**
	 * In the exponential case ({@link #multiplier()} > 0) set this to true to have the
	 * backoff delays randomized, so that the maximum delay is multiplier times the
	 * previous delay and the distribution is uniform between the two values.
	 *
	 * @return the flag to signal randomization is required (default false)
	 */
	boolean random() default false;

}

java复制代码@Component
public class PlatformClassService {
    @Retryable(
        // 重试异常的异常类型
        value = {Exception.class},
        // 最大重试次数
        maxAttempts = 5,
        // 设置回退延迟时间
        backoff = @Backoff(delay = 500),
        // 配置回调方法名称
        listeners = "retryListener"
    )
    public void call() {
        System.out.println("call...");
        throw new RuntimeException("手工异常");
    }
}

java复制代码// 初始延迟2秒，然后之后验收1.5倍延迟重试，总重试次数4
@Retryable(value = {Exception.class}, maxAttempts = 4, backoff = @Backoff(delay = 2000L, multiplier = 1.5))

java复制代码/**
  * 注解调用
  */
@Bean
public RetryListener retryListener() {
    return new RetryListener() {
        @Override
        public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
            System.out.println("open context = " + context + ", callback = " + callback);
            // 返回true继续执行后续调用
            return true;
        }

        @Override
        public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback,
                                                   Throwable throwable) {
            System.out.println("close context = " + context + ", callback = " + callback);
        }
        @Override
        public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback,
                                                     Throwable throwable) {
            System.out.println("onError context = " + context + ", callback = " + callback);
        }
    };
}

java复制代码@RestController
public class SpringRetryController {
    @Resource
    private PlatformClassService platformClassService;
    
    @RequestMapping("/retryPlatformCall")
    public Object retryPlatformCall() {
        try {
            platformClassService.call();
        } catch (Exception e) {
            return "尝试调用失败";
        }
        return "retryPlatformCall";
    }
}

sql复制代码general options:
      --help                                      print usage
      --version                                   print the tool version and exit

verbosity options:
  -v, --verbose=<level>                           more detailed log output (include multiple
                                                  times for more verbosity, e.g. -vvvvv, or
                                                  specify a numeric value, e.g. --verbose=N)
      --quiet                                     hide all log output

connection options:
  -h, --host=<hostname>                           mongodb host to connect to (setname/host1,host2
                                                  for replica sets)
      --port=<port>                               server port (can also use --host hostname:port)

authentication options:
  -u, --username=<username>                       username for authentication
  -p, --password=<password>                       password for authentication
      --authenticationDatabase=<database-name>    database that holds the user's credentials
      --authenticationMechanism=<mechanism>       authentication mechanism to use

namespace options:
  -d, --db=<database-name>                        database to use
  -c, --collection=<collection-name>              collection to use

output options:
  -f, --fields=<field>[,<field>]*                 comma separated list of field names (required
                                                  for exporting CSV) e.g. -f "name,age"
      --fieldFile=<filename>                      file with field names - 1 per line
      --type=<type>                               the output format, either json or csv (defaults
                                                  to 'json')
  -o, --out=<filename>                            output file; if not specified, stdout is used
      --jsonArray                                 output to a JSON array rather than one object
                                                  per line
      --pretty                                    output JSON formatted to be human-readable

querying options:
  -q, --query=<json>                              query filter, as a JSON string, e.g.,
                                                  '{x:{$gt:1}}'
      --queryFile=<filename>                      path to a file containing a query filter (JSON)
  -k, --slaveOk                                   allow secondary reads if available (default
                                                  true)
      --readPreference=<string>|<json>            specify either a preference name or a
                                                  preference json object
      --forceTableScan                            force a table scan (do not use $snapshot)
      --skip=<count>                              number of documents to skip
      --limit=<count>                             limit the number of documents to export
      --sort=<json>                               sort order, as a JSON string, e.g. '{x:1}'
      --assertExists                              if specified, export fails if the collection
                                                  does not exist (false)

css复制代码mongoexport --db users --collection contacts --csv --fieldFile fields.txt --out /opt/backups/contacts.csv

css复制代码mongoexport --db sales --collection contacts --out contacts.json --journal

sql复制代码general options:
      --help                                      print usage
      --version                                   print the tool version and exit

verbosity options:
  -v, --verbose=<level>                           more detailed log output (include multiple
                                                  times for more verbosity, e.g. -vvvvv, or
                                                  specify a numeric value, e.g. --verbose=N)
      --quiet                                     hide all log output

connection options:
  -h, --host=<hostname>                           mongodb host to connect to (setname/host1,host2
                                                  for replica sets)
      --port=<port>                               server port (can also use --host hostname:port)

authentication options:
  -u, --username=<username>                       username for authentication
  -p, --password=<password>                       password for authentication
      --authenticationDatabase=<database-name>    database that holds the user's credentials
      --authenticationMechanism=<mechanism>       authentication mechanism to use

namespace options:
  -d, --db=<database-name>                        database to use
  -c, --collection=<collection-name>              collection to use

input options:
  -f, --fields=<field>[,<field>]*                 comma separated list of field names, e.g. -f
                                                  name,age
      --fieldFile=<filename>                      file with field names - 1 per line
      --file=<filename>                           file to import from; if not specified, stdin is
                                                  used
      --headerline                                use first line in input source as the field
                                                  list (CSV and TSV only)
      --jsonArray                                 treat input source as a JSON array
      --type=<type>                               input format to import: json, csv, or tsv
                                                  (defaults to 'json')

ingest options:
      --drop                                      drop collection before inserting documents
      --ignoreBlanks                              ignore fields with empty values in CSV and TSV
      --maintainInsertionOrder                    insert documents in the order of their
                                                  appearance in the input source
  -j, --numInsertionWorkers=<number>              number of insert operations to run concurrently
                                                  (defaults to 1)
      --stopOnError                               stop importing at first insert/upsert error
      --upsert                                    insert or update objects that already exist
      --upsertFields=<field>[,<field>]*           comma-separated fields for the query part of
                                                  the upsert
      --writeConcern=<write-concern-specifier>    write concern options e.g. --writeConcern
                                                  majority, --writeConcern '{w: 3, wtimeout: 500,
                                                  fsync: true, j: true}' (defaults to 'majority')
      --bypassDocumentValidation                  bypass document validation

css复制代码mongoimport --db users --collection contacts --type csv --file /opt/backups/contacts.csv

css复制代码mongoimport --collection contacts --file contacts.json --journal

bash复制代码./mongoexport -d DataBaseName -c CollectionName -o bak.dat

bash复制代码./mongoexport -d user -c guset -o guset.dat

bash复制代码sudo mv /tmp/bak.dat /db/mongo/bin

bash复制代码cd /db/mongo/bin

bash复制代码./mongoimport -h 127.0.0.1:port -u xxx -p xxx-d DataBaseName -c CollectionName bak.dat

sql复制代码./mongoimport -h 127.0.0.1:27017 -u user -p user -d guset -c guset bak.dat

vbnet复制代码 Set<String> keys = redisTemplate.execute((RedisCallback<Set<String>>) connection -> {
            Set<String> keysTmp = new HashSet<>();
            Cursor<byte[]> cursor = connection.scan(new ScanOptions.ScanOptionsBuilder().match(REDIS_KEY_NAME + "*").count(1000).build());
            while (cursor.hasNext()) {
                keysTmp.add(new String(cursor.next()));
            }
            return keysTmp;
        });

java复制代码cName = InpList.get(0).replace(",", ".");

                    cCode = InpList.get(1).replace(",", ".");

                    cAlpha2 = InpList.get(2).replace(",", ".");

                    cAbreviation = InpList.get(3).replace(",", ".");

                    dYear = InpList.get(4).replace(",", ".");

                    dPoliticalCompatibility = InpList.get(5).replace(",", ".");

                    dRankPoliticalCompatibility = InpList.get(6).replace(",", ".");

                    dEconomicCompatibility = InpList.get(7).replace(",", ".");

                    dRankEconomicCompatibility = InpList.get(8).replace(",", ".");

                    dMilitaryCompatibility = InpList.get(9).replace(",", ".");

                    dRankMilitaryCompatibility = InpList.get(10).replace(",", ".");

                    dDemoScore = InpList.get(11).replace(",", ".");

                    dRankDemoScore = InpList.get(12).replace(",", ".");

                    dEnvironmentalCompatibility = InpList.get(13).replace(",", ".");

                    dRankEnvironmentalCompatibility = InpList.get(14).replace(",", ".");

                    dSumCompatibility = InpList.get(15).replace(",", ".");

                    dRankCompatibility = InpList.get(16).replace(",", ".");

                    dPoliticalUtility = InpList.get(17).replace(",", ".");

                    dRankPoliticalUtility = InpList.get(18).replace(",", ".");

                    dEconomicUtility = InpList.get(19).replace(",", ".");

                    dRankEconomicUtility = InpList.get(20).replace(",", ".");

                    dMilitaryUtility = InpList.get(21).replace(",", ".");

                    dRankMilitaryUtility = InpList.get(22).replace(",", ".");

                    dEnvironmentalUtility = InpList.get(23).replace(",", ".");

                    dRankEnvironmentalUtility = InpList.get(24).replace(",", ".");

                    dSumUtility = InpList.get(25).replace(",", ".");

                    dRankUtility = InpList.get(26).replace(",", ".");

                    dPoliticalScore = InpList.get(27).replace(",", ".");

                    dRankPoliticalScore = InpList.get(28).replace(",", ".");

                    dEconomicScore = InpList.get(29).replace(",", ".");

                    dRankEconomicScore = InpList.get(30).replace(",", ".");

                    dMilitaryScore = InpList.get(31).replace(",", ".");

                    dRankMilitaryScore = InpList.get(32).replace(",", ".");

                    dEnvironmentalScore = InpList.get(33).replace(",", ".");

                    dRankEnvironmentalScore = InpList.get(34).replace(",", ".");

                    dAggregate = InpList.get(35).replace(",", ".");

                    dRankAggregate = InpList.get(36).replace(",", ".");

java复制代码/**

 * {@inheritDoc}

 */

@Override

public CloseableHttpResponse execute(

        final HttpUriRequest request,

        final HttpContext context) throws IOException, ClientProtocolException {

    Args.notNull(request, "HTTP request");

    return doExecute(determineTarget(request), request, context);

}

private static HttpHost determineTarget(final HttpUriRequest request) throws ClientProtocolException {

    // A null target may be acceptable if there is a default target.

    // Otherwise, the null target is detected in the director.

    HttpHost target = null;

    final URI requestURI = request.getURI();

    if (requestURI.isAbsolute()) {

        target = URIUtils.extractHost(requestURI);

        if (target == null) {

            throw new ClientProtocolException("URI does not specify a valid host name: "

                    + requestURI);

        }

    }

    return target;

}

java复制代码public class T {

    private Set<String> pns = new HashSet();

    private int s = 0;

    private Boolean f(String n) {return pns.contains(n);}

    int getS() {return s;}

    int s(List<T> ts, String n) {

        for (T t :ts) 

            if (t.f(n)) 

                return t.getS();

        return 0;

    }

}

java复制代码/**

 * 获取球队比赛得分

 **/

public class Team {

    private Set<String> playerNames = new HashSet(); //保证名字不重复

    private int score = 0; //默认为零

    

    /**

     * 判断是否包含球员

     * @param playerName

     * @return

     */

    private Boolean containsPlayer(String playerName) {

        return playerNames.contains(playerName);

    }

    

    /**

     * 知道队伍，直接获取分数

     * @return

     */

    public int getScore() {

        return score;

    }

    

    /**

     * 通过队员名字查找所属队伍分数

     * @param teams 支持多个队伍

     * @param playerName 

     * @return 兜底为0分，不出现负分

     */

    public int getTeamScoreForPlayer(List<Team> teams, String playerName) {

        for (Team team :teams) {

            if (team.containsPlayer(playerName)) {

                return team.getScore();

            }

        }

        return 0;

    }

}

java复制代码public List<User> getUsers(int id) {

    List<User> result = new ArrayList<>();

    User user = getUserById(id);

    if (null != user) {

        Manager manager = user.getManager();

        if (null != manager) {

            List<User> users = manager.getUsers();

            if (null != users && users.size() > 0) {

                for (User user1 : users) {

                    if (user1.getAge() >= 35 && "MALE".equals(user1.getSex())) {

                        result.add(user1);

                    }

                }

            } else {

                System.out.println("获取员工列表失败");

            }

        } else {

            System.out.println("获取领导信息失败");

        }

    } else {

        System.out.println("获取员工信息失败");

    }

    return result;

}

java复制代码public List<User> getStudents(int uid) {

    List<User> result = new ArrayList<>();

    User user = getUserByUid(uid);

    if (null == user) {

        System.out.println("获取员工信息失败");

        return result;

    }

    Manager manager = user.getManager();

    if (null == manager) {

        System.out.println("获取领导信息失败");

        return result;

    }

    List<User> users = manager.getUsers();

    if (null == users || users.size() == 0) {

        System.out.println("获取员工列表失败");

        return result;

    }

    for (User user1 : users) {

        if (user1.getAge() > 35 && "MALE".equals(user1.getSex())) {

            result.add(user1);

        }

    }

    return result;

}

java复制代码
@Service
public class Scheduling1Service {

    //每2秒执行一次(若上次任务执行时间超过2秒，则立即执行，否则从上一个任务开始时算起2秒后执行本次任务)
    @Scheduled(fixedRate = 2000)
    public void test1() throws InterruptedException {
        Thread.sleep(1000L);//模拟定时任务执行耗费了1s
        Thread.sleep(3000L);//模拟定时任务执行耗费了3s
        Date date = new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(format.format(date)+"==>SchedulingService.test1 is called");
    }

    //上一个任务执行完2秒后，再执行本次任务
    @Scheduled(fixedDelay = 2000)
    public void test2() throws InterruptedException {
        Thread.sleep(3000L);//模拟定时任务执行耗费了3s
        Date date = new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(format.format(date)+"==>SchedulingService.test2 is called");
    }

    //支持corn表达式
    @Scheduled(cron = "0 0 1 * * ?")//每天凌晨1点执行
    public void test3() throws InterruptedException {
        Date date = new Date();
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(format.format(date)+"==>SchedulingService.test3 is called");
    }
}

yaml复制代码<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

java复制代码@Service
public class Scheduling3Service implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        scheduledTaskRegistrar.addTriggerTask(
                new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("cccccccc");
                    }
                },
                triggerContext -> {
                    return new CronTrigger("0/1 * * * * ? ").nextExecutionTime(triggerContext);
                }
        );
    }
}