高并发Day14--京淘前台搭建

<parent>   <groupId>com.jt</groupId>   <artifactId>jt</artifactId>   <version>0.0.1-SNAPSHOT</version> </parent> <artifactId>jt-web</artifactId> <packaging>war</packaging>  <dependencies><dependency><groupId>com.jt</groupId><artifactId>jt-common</artifactId><version>0.0.1-SNAPSHOT</version></dependency></dependencies>

<build><plugins><!--跳过测试类打包 --><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-surefire-plugin</artifactId><configuration><skip>true</skip></configuration></plugin><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>

//启动时不加载数据源的配置@SpringBootApplication(exclude=DataSourceAutoConfiguration.class)public class SpringBootRun {
public static void main(String[] args) {
SpringApplication.run(SpringBootRun.class,args);}}

#配置前台管理服务器server {listen 80;server_name www.jt.com;
location  / {

#实现http请求的转发proxy_pass http://localhost:8092;
}}

chrome://net-internals/#hsts

@Configuration              //web.xmlpublic class MvcConfigurer implements WebMvcConfigurer{
//开启匹配后缀型配置 后缀任意.@Overridepublic void configurePathMatch(PathMatchConfigurer configurer) {
configurer.setUseSuffixPatternMatch(true);}}

<!--添加httpClient jar包 --><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId></dependency>5.3  入门案例/*** 1.实例化httpClient对象* 2.定义请求的路径  String* 3.定义请求的对象  get/post/put/delete* 4.发起请求  获取响应对象* 5.判断返回值的状态 200/504/404/500/400 请求参数类型不匹配/406 返回值类型异常* 6.如果返回值正确, 动态获取响应数据.* @throws IOException* @throws ClientProtocolException*/@Testpublic void doGet() throws ClientProtocolException, IOException {HttpClient httpClient = HttpClients.createDefault();String url = "http://www.baidu.com";HttpGet get = new HttpGet(url);HttpResponse response = httpClient.execute(get);if(200 == response.getStatusLine().getStatusCode()) {System.out.println("请求正确!!!!!!");HttpEntity entity = response.getEntity();//将entity中携带的信息转化为字符串String result = EntityUtils.toString(entity,"utf-8");System.out.println(result);}else {System.out.println("请求异常!!!!!");}
}

@Configuration@PropertySource(value="classpath:/properties/httpClient.properties")public class HttpClientConfig {@Value("${http.maxTotal}")private Integer maxTotal;            //最大连接数

@Value("${http.defaultMaxPerRoute}")private Integer defaultMaxPerRoute;        //最大并发链接数

@Value("${http.connectTimeout}")private Integer connectTimeout;          //创建链接的最大时间

@Value("${http.connectionRequestTimeout}")private Integer connectionRequestTimeout;    //链接获取超时时间

@Value("${http.socketTimeout}")private Integer socketTimeout;            //数据传输最长时间

@Value("${http.staleConnectionCheckEnabled}")private boolean staleConnectionCheckEnabled;   //提交时检查链接是否可用

//定义httpClient链接池@Bean(name="httpClientConnectionManager")public PoolingHttpClientConnectionManager getPoolingHttpClientConnectionManager() {PoolingHttpClientConnectionManager manager = new PoolingHttpClientConnectionManager();manager.setMaxTotal(maxTotal);  //设定最大链接数manager.setDefaultMaxPerRoute(defaultMaxPerRoute);  //设定并发链接数return manager;}

//定义HttpClient/*** 实例化连接池，设置连接池管理器。* 这里需要以参数形式注入上面实例化的连接池管理器     @Qualifier 指定bean标签进行注入*/@Bean(name = "httpClientBuilder")public HttpClientBuilder getHttpClientBuilder(@Qualifier("httpClientConnectionManager")PoolingHttpClientConnectionManager httpClientConnectionManager){

//HttpClientBuilder中的构造方法被protected修饰，所以这里不能直接使用new来实例化一个HttpClientBuilder,可以使用HttpClientBuilder提供的静态方法create()来获取HttpClientBuilder对象HttpClientBuilder httpClientBuilder = HttpClientBuilder.create();httpClientBuilder.setConnectionManager(httpClientConnectionManager);return httpClientBuilder;}

/***   注入连接池，用于获取httpClient* @param httpClientBuilder* @return** 1.定义池对象* 2.创建builder对象 关联池* 3.利用builder实例化对象*/@Beanpublic CloseableHttpClient getCloseableHttpClient(@Qualifier("httpClientBuilder") HttpClientBuilder httpClientBuilder){

return httpClientBuilder.build();}

/*** Builder是RequestConfig的一个内部类 * 通过RequestConfig的custom方法来获取到一个Builder对象 * 设置builder的连接信息* @return*/@Bean(name = "builder")public RequestConfig.Builder getBuilder(){RequestConfig.Builder builder = RequestConfig.custom();return builder.setConnectTimeout(connectTimeout).setConnectionRequestTimeout(connectionRequestTimeout).setSocketTimeout(socketTimeout).setStaleConnectionCheckEnabled(staleConnectionCheckEnabled);}

/*** 使用builder构建一个RequestConfig对象* @param builder* @return*/@Beanpublic RequestConfig getRequestConfig(@Qualifier("builder") RequestConfig.Builder builder){return builder.build();}}

@Component  //交给spring容器管理public class HttpClientClose extends Thread{@Autowiredprivate PoolingHttpClientConnectionManager manage;private volatile boolean shutdown;  //开关 volatitle表示多线程可变数据,一个线程修改,其他线程立即修改
public HttpClientClose() {///System.out.println("执行构造方法,实例化对象");//线程开启启动this.start();}
//以异步的形式关闭httpClient对象@Overridepublic void run() {try {//如果服务没有关闭,执行线程while(!shutdown) {synchronized (this) {wait(5000);      //等待5秒//System.out.println("线程开始执行,关闭超时链接");//关闭超时的链接PoolStats stats = manage.getTotalStats();int av = stats.getAvailable();  //获取可用的线程数量int pend = stats.getPending();  //获取阻塞的线程数量int lea = stats.getLeased();    //获取当前正在使用的链接数量int max = stats.getMax();//System.out.println("max/"+max+":  av/"+av+":  pend/"+pend+":   lea/"+lea);manage.closeExpiredConnections();}}} catch (Exception e) {e.printStackTrace();throw new RuntimeException();}

super.run();}

//关闭清理无效连接的线程@PreDestroy  //容器关闭时执行该方法.public void shutdown() {shutdown = true;synchronized (this) {//System.out.println("关闭全部链接!!");notifyAll(); //全部从等待中唤醒.执行关闭操作;}}}

//简化httpClient调用工具API@Servicepublic class HttpClientService {
@Autowiredprivate HttpClient httpClient;@Autowiredprivate RequestConfig requestConfig;
/***   参数:*     1.url 访问地址*     2.Map<String,String> params*     3.字符集编码*   问题:*      1.字符集非空判断,如果为空 设定默认值utf-8*      2.判断用户是否有参数*        有   url?name=value&name2=value2*       无    url** @return*/public String doGet(String url,Map<String,String> params,String charset) {
//1.判断用户是否传递参数if(StringUtils.isEmpty(charset)) {//如果为null则设定默认值charset = "UTF-8";}
//2.判断用户是否传参if(params != null) {url +="?";
//url?name1=valu1&name2=value2&for (Map.Entry<String,String> entry : params.entrySet()) {
String name = entry.getKey();String value = entry.getValue();url += name+"="+value+"&";}//截取字符串中多余的&url = url.substring(0, url.length()-1);}
//3.定义请求对象HttpGet httpGet = new HttpGet(url);httpGet.setConfig(requestConfig);
//4.发起http请求String result = null;try {HttpResponse response = httpClient.execute(httpGet);
if(response.getStatusLine().getStatusCode() == 200) {HttpEntity entity = response.getEntity();result = EntityUtils.toString(entity, charset);}} catch (IOException e) {
e.printStackTrace();throw new RuntimeException(e);}
return result;}
public String doGet(String url) {
return doGet(url, null, null);}
public String doGet(String url,Map<String,String> params) {
return doGet(url, params, null);}}

@Autowiredprivate HttpClientService httpClient;
@Testpublic void testGet() {
String url = "https://www.baidu.com";String result = httpClient.doGet(url);System.out.println(result);}

@RestController@RequestMapping("/web/item")public class WebItemController {
@Autowiredprivate ItemService itemService;/*** http://manage.jt.com/web/item业务/findItemById?id=101&name=xxx* http://manage.jt.com/web/item业务/findItemById/101/xxxx*/
@RequestMapping("/findItemById/{itemId}")public Item findItemById(@PathVariable Long itemId) {
return itemService.findItemById(itemId);}}

@Overridepublic Item findItemById(Long itemId) {
return itemMapper.selectById(itemId);}