1.JT-SSO系统搭建
1.1编辑User pojo
package com.jt.pojo;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.experimental.Accessors;
@Data
@TableName("tb_user")
@Accessors(chain = true)
public class User extends BasePojo {
@TableId(type= IdType.AUTO)//设置主键自增
private Long id;//用户编号
private String username;//用户名
private String password;//密码 MD5方式进行加密
private String phone;//电话
private String email;//暂时用电话号码
}
1.2创建jt-sso项目
1.2.1新建项目
1.2.2添加继承/依赖/插件
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<artifactId>jt</artifactId>
<groupId>com.jt</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>jt-sso</artifactId>
<dependencies>
<dependency>
<groupId>com.jt</groupId>
<artifactId>jt-common</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
</dependencies>
<!--添加插件 有main方法时 需要添加插件-->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
1.2.3编辑结构代码
1.2.4编辑UserController
完成jt-sso案例用户访问测试
1.2.5编辑UserService
编辑service完成用户信息的获取
1.2.6配置ngnix/hosts
要求:通过sso.jt.com的方式访问http://localhost:8093
1.编辑hosts文件
2.编辑Nginx配置文件
3.测试效果
2.用户数据校验
2.1跨域页面分析
2.1.1url分析
2.1.2js分析
检索页面js ctrl+h
2.2用户接口文档说明
2.3编辑jt-sso Usercontroller
package com.jt.controller;
import com.fasterxml.jackson.databind.util.JSONPObject;
import com.jt.pojo.User;
import com.jt.service.UserService;
import com.jt.vo.SysResult;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
/**
* 测试查询user表中的所有数据
* @return
*/
@RequestMapping("/findAll")
public List<User> findAll(){
return userService.findAll();
}
/**
* 完成用户数据校验JT-SSO项目
* url地址:http://sso.jt.com/user/check/{param}/{type}
* 参数:param 校验数据/type 检验类型 /callback 回调函数
* 返回值:sysredult vo对象 data:true数据存在/false 数据不存在
* 提示:该请求是JSONP请求方式,所以需要特定的格式封装
*/
@RequestMapping("/check/{param}/{type}")
public JSONPObject checkUser(@PathVariable String param,@PathVariable Integer type,String callback){
boolean flag=userService.checkUser(param,type); //表示数据不存在可以使用
SysResult sysResult=SysResult.success(flag);
return new JSONPObject(callback, sysResult);
}
}
2.4编辑jt-sso userService实现类
package com.jt.service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.jt.mapper.UserMapper;
import com.jt.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@Service
public class UserServiceImpl implements UserService{
private static Map<Integer,String > columnMap=new HashMap<Integer ,String>();
static {
columnMap.put(1,"username");
columnMap.put(2,"phone");
columnMap.put(3,"email");
}
@Autowired
private UserMapper userMapper;
@Override
public List<User> findAll() {
return userMapper.selectList(null);
}
//如果数据库中存在 返回true 不存在返回false
//如何判断 数据库中是否存在
//type=1 username ,type=2 phone ,type=3 email
@Override
public boolean checkUser(String param, Integer type) {
String column=columnMap.get(type);
QueryWrapper queryWrapper=new QueryWrapper();
queryWrapper.eq(column,param);
int count=userMapper.selectCount(queryWrapper);
//return count>0?true:false;
// count=1/0;
return count>0;
}
}
2.5关于全局异常处理
package com.jt.aop;
import com.fasterxml.jackson.databind.util.JSONPObject;
import com.jt.vo.SysResult;
import org.springframework.util.StringUtils;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import javax.servlet.http.HttpServletRequest;
//定义全局异常的处理机制
@RestControllerAdvice
public class SystemAOP {
/**
* 业务说明: 由于jsonp跨域调用即使错误,也应该按照callback(JSON)的方式返回
* 所以应该重构全局异常处理.,关于JSONP返回的问题
* 思路: 由于jsonp调用一般都会携带callback参数 所以可以通过该参数是否存在判断是否为JSONP调用!!!
* @param
* @return
*/
@ExceptionHandler({RuntimeException.class})
public Object result(Exception e, HttpServletRequest request){
e.printStackTrace(); //打印错误日志
String callback = request.getParameter("callback");
if(StringUtils.hasLength(callback)){
//如果callback有值 按照jsonp方式返回
return new JSONPObject(callback, SysResult.fail());
}
return SysResult.fail();
}
}
2.6编辑页面js
3.HttpClinet介绍
3.1远程调用分析
3.2HttpClient介绍
HTTP协议是internet上使用得最多、最重要的协议之一,越来越多的java应用程序需要直接通过HTTP协议来访问网络资源。虽然JDK库本身的Java net 包中已经提供了访问HTTP协议的基本功能,但是对于大部分应用程序来说,JDK库本身提供的功能还不够丰富和灵活。HttpClinet是Apache jakrta Common 下的子项目,依赖提供高效的,最新的,功能丰富的支持HTTP协议的客户端编程工具包,并且他支持了HTTP协议最新的版本和建议。并且它支持 HTTP 协议最新的版本和建议。HttpClient 已经应用在很多的项目中,比如 Apache Jakarta 上很著名的另外两个开源项目 Cactus 和 HTMLUnit 都使用了 HttpClient。Commons HttpClient项目现已终止,不再开发。 它已被Apache HttpComponents项目里的HttpClient和HttpCore模块取代,它们提供了更好的性能和更大的灵活性。 [1]
3.3HttpClient入门案例
3.3.1编辑Pom.xml文件
<!--添加httpClient jar包 -->
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</dependency>
3.3.2入门案例
package com.jt;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.junit.jupiter.api.Test;
import java.io.IOException;
public class TestHttpClient {
/**
* 1.实例化HttpClient对象
* 2.定义url地址
* 3.封装请求方式GET/POST/PUT....
* 4.发送请求获取响应的结果.response
* 5.判断响应是否正确. 200表示请求正确,获取响应的结果.
* 6.解析服务器返回值.获取有效数据
*/
@Test//在java代码中发起http请
public void testGet() throws IOException {
HttpClient httpClient = HttpClients.createDefault();
String url = "https://www.cctv.com/";
HttpGet httpGet = new HttpGet(url);
HttpResponse httpResponse = httpClient.execute(httpGet);
int status = httpResponse.getStatusLine().getStatusCode(); //获取状态码
if(status == 200 ){
HttpEntity entity = httpResponse.getEntity(); //获取响应的实体对象
String result = EntityUtils.toString(entity, "UTF-8");
System.out.println(result);
}
}
}
3.3.3关于HttpClient案例
需求:用户通过浏览器网址http://www.jt.com/user/findAll请求,要求jt-sso中的所有的用户信息。
提示:jt-web服务器没有办法直接访问数据库。。。
js-sso服务器访问数据
jt-web向jt-sso发起请求为http://sso.jt.com/user/findAll
1).jt-web编辑userController
2).jt-web编辑service实现类
package com.jt.service;
import com.jt.pojo.User;
import com.jt.util.ObjectMapperUtil;
import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.stereotype.Service;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
@Service
public class UserServiceImpl implements UserService{
@Override
public List<User> findAll() {
List<User> userList=new ArrayList<>();
String url="http://sso.jt.com/user/findAll";
HttpGet httpGet=new HttpGet(url);
HttpClient httpClient= HttpClients.createDefault();
try {
HttpResponse httpResponse= httpClient.execute(httpGet);
if(httpResponse.getStatusLine().getStatusCode()==200){
//说明请求正确
String json= EntityUtils.toString(httpResponse.getEntity(),"UTF-8");
userList= ObjectMapperUtil.toObj(json,userList.getClass());
//拿到对象后,按照指定的业务要求,对数据进行二次加工 解密/添加某些数据
}
} catch (IOException e) {
e.printStackTrace();
}
return userList;
}
}
3).jt-sso编辑usercontroller接收jt-web发送过来的请求然后调用service层调用mapper层将数据查出来返回给jt-web