JAVA springcloud b2b2c多用户商城系统源码（二十三）异步方法

- 日理万妓 2022-10-01 12:42 151阅读 0赞

## 创建工程 ##

在pom文件引入相关依赖：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>&lt;dependency&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;groupId&gt;org.springframework.boot&lt;/groupId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;artifactId&gt;spring-boot-starter&lt;/artifactId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;/dependency&gt;</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;dependency&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;groupId&gt;org.springframework&lt;/groupId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;artifactId&gt;spring-web&lt;/artifactId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;/dependency&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;dependency&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;groupId&gt;com.fasterxml.jackson.core&lt;/groupId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;artifactId&gt;jackson-databind&lt;/artifactId&gt;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>&lt;/dependency&gt;</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

创建一个接收数据的实体：

创建一个请求的　githib的service:

通过，RestTemplate去请求，另外加上类@Async 表明是一个异步任务。

开启异步任务：

复制代码

通过@EnableAsync开启异步任务；并且配置AsyncConfigurerSupport，比如最大的线程池为2.

## 测试 ##

测试代码如下：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div> 
    <div>
      4 
    </div> 
    <div>
      5 
    </div> 
    <div>
      6 
    </div> 
    <div>
      7 
    </div> 
    <div>
      8 
    </div> 
    <div>
      9 
    </div> 
    <div>
      10 
    </div> 
    <div>
      11 
    </div> 
    <div>
      12 
    </div> 
    <div>
      13 
    </div> 
    <div>
      14 
    </div> 
    <div>
      15 
    </div> 
    <div>
      16 
    </div> 
    <div>
      17 
    </div> 
    <div>
      18 
    </div> 
    <div>
      19 
    </div> 
    <div>
      20 
    </div> 
    <div>
      21 
    </div> 
    <div>
      22 
    </div> 
    <div>
      23 
    </div> 
    <div>
      24 
    </div> 
    <div>
      25 
    </div> 
    <div>
      26 
    </div> 
    <div>
      27 
    </div> 
    <div>
      28 
    </div> 
    <div>
      29 
    </div> 
    <div>
      30 
    </div> 
    <div>
      31 
    </div> 
    <div>
      32 
    </div> 
    <div>
      33 
    </div> 
    <div>
      34 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>@Component</code> 
     </div> 
     <div> 
      <code>public</code> 
      <code>class</code> 
      <code>AppRunner </code> 
      <code>implements</code> 
      <code>CommandLineRunner { </code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>private</code> 
      <code>static</code> 
      <code>final</code> 
      <code>Logger logger = LoggerFactory.getLogger(AppRunner.</code> 
      <code>class</code> 
      <code>);</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>private</code> 
      <code>final</code> 
      <code>GitHubLookupService gitHubLookupService;</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>public</code> 
      <code>AppRunner(GitHubLookupService gitHubLookupService) { </code> 
     </div> 
     <div> 
      <code> </code> 
      <code>this</code> 
      <code>.gitHubLookupService = gitHubLookupService;</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>}</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>@Override</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>public</code> 
      <code>void</code> 
      <code>run(String... args) </code> 
      <code>throws</code> 
      <code>Exception { </code> 
     </div> 
     <div> 
      <code> </code> 
      <code>// Start the clock</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>long</code> 
      <code>start = System.currentTimeMillis();</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>// Kick of multiple, asynchronous lookups</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>Future&lt;User&gt; page1 = gitHubLookupService.findUser(</code> 
      <code>"PivotalSoftware"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>Future&lt;User&gt; page2 = gitHubLookupService.findUser(</code> 
      <code>"CloudFoundry"</code> 
      <code>);</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>Future&lt;User&gt; page3 = gitHubLookupService.findUser(</code> 
      <code>"Spring-Projects"</code> 
      <code>);</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>// Wait until they are all done</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>while</code> 
      <code>(!(page1.isDone() &amp;&amp; page2.isDone() &amp;&amp; page3.isDone())) { </code> 
     </div> 
     <div> 
      <code> </code> 
      <code>Thread.sleep(</code> 
      <code>10</code> 
      <code>); </code> 
      <code>//10-millisecond pause between each check</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>}</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code> </code> 
      <code>// Print results, including elapsed time</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>logger.info(</code> 
      <code>"Elapsed time: "</code> 
      <code>+ (System.currentTimeMillis() - start));</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>logger.info(</code> 
      <code>"--&gt; "</code> 
      <code>+ page1.get());</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>logger.info(</code> 
      <code>"--&gt; "</code> 
      <code>+ page2.get());</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>logger.info(</code> 
      <code>"--&gt; "</code> 
      <code>+ page3.get());</code> 
     </div> 
     <div> 
      <code> </code> 
      <code>}</code> 
     </div> 
     <div> 
     </div> 
     <div> 
      <code>}</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

启动程序，控制台会打印：

<table> 
 <tbody> 
  <tr> 
   <td> 
    <div>
      1 
    </div> 
    <div>
      2 
    </div> 
    <div>
      3 
    </div></td> 
   <td> 
    <div> 
     <div> 
      <code>2017</code> 
      <code>-</code> 
      <code>04</code> 
      <code>-</code> 
      <code>30</code> 
      <code>13</code> 
      <code>:</code> 
      <code>11</code> 
      <code>:</code> 
      <code>10.351</code> 
      <code>INFO </code> 
      <code>1511</code> 
      <code>— [ GithubLookup-</code> 
      <code>1</code> 
      <code>] com.forezp.service.GitHubLookupService : Looking up PivotalSoftware</code> 
     </div> 
     <div> 
      <code>2017</code> 
      <code>-</code> 
      <code>04</code> 
      <code>-</code> 
      <code>30</code> 
      <code>13</code> 
      <code>:</code> 
      <code>11</code> 
      <code>:</code> 
      <code>10.351</code> 
      <code>INFO </code> 
      <code>1511</code> 
      <code>— [ GithubLookup-</code> 
      <code>2</code> 
      <code>] com.forezp.service.GitHubLookupService : Looking up CloudFoundry</code> 
     </div> 
     <div> 
      <code>2017</code> 
      <code>-</code> 
      <code>04</code> 
      <code>-</code> 
      <code>30</code> 
      <code>13</code> 
      <code>:</code> 
      <code>11</code> 
      <code>:</code> 
      <code>13.144</code> 
      <code>INFO </code> 
      <code>1511</code> 
      <code>— [ GithubLookup-</code> 
      <code>2</code> 
      <code>] com.forezp.service.GitHubLookupService : Looking up Spring-Projects</code> 
     </div> 
    </div></td> 
  </tr> 
 </tbody> 
</table>

架构代码如下:

Spring Cloud大型企业分布式微服务云构建的B2B2C电子商务平台源码请加企鹅求求：一零三八七七四六二六

转载于:https://juejin.im/post/5c91eaa46fb9a070cf6bcb43