Back to Sa Token

消息推送机制

sa-token-doc/sso/message-push.md

1.45.07.1 KB
Original Source

消息推送机制

消息推送机制简单来讲就是:sso-client 端按照特点格式构建一个 http 请求,调用 sso-server 端的 /sso/pushS 接口,sso-server 接收到消息后做出处理回应 sso-client 端。

消息推送是相互的,sso-server 端也可以构建 http 请求,调用 sso-client 端的 /sso/pushC 接口。

消息推送机制是应用与认证中心相互沟通的桥梁,ticket 校验、单点注销等行为都是依赖消息推送机制来实现的。

本篇将介绍在 Sa-Token SSO 模块中,sso-server 端和 sso-client 端分别内置了哪些消息模块,以及如何自定义消息处理器。

1、sso-server 端内置消息处理器

1.1、checkTicket(ticket 校验)

作用:在 SSO 模式三下为 sso-client 提供 ticket 校验能力,返回 loginId 等数据

url
http://{sso-server主机地址}/sso/pushS

接收参数:

参数是否必填说明
msgType消息类型,此处填 checkTicket
ticketticket 码
client客户端标识,可不填,代表是一个匿名应用
ssoLogoutCallClient 端单点注销时 - 回调 URL 参数名称 (匿名 Client 时使用)
timestamp当前时间戳,13位
nonce随机字符串
sign签名,生成算法示例:md5( client={client值}&msgType={checkTicket}&nonce={随机字符串}&ticket={ticket码}&timestamp={13位时间戳}&key={secretkey秘钥} )

<font color="#080" >签名算法规则:将所有参数按照字典顺序依次排列(key除外,挂在最后面),然后进行 md5 摘要。以下不再赘述。</font>

返回值示例:

js
{
  "code": 200,   // 返回 200=成功,500=失败
  "msg": "ok",
  "data": "10001",
  "loginId": "10001",   // 此 ticket 对应的认证中心 loginId 
  "tokenValue": "5db12b02-9c8e-4e36-8ed9-bf295caed80e",   // 对应的认证中心会话 token 
  "deviceId": "MxOTCLWi5NXGqFQZBFdsH66Ni5YTJ8q0",   // 对应的认证中心登录设备 id
  "remainTokenTimeout": 2591999,   // token 剩余有效期
  "remainSessionTimeout": 2591999   // Access-Session 会话剩余有效期
}

1.2、signout(单点注销)

作用:为 sso-client 提供单点注销能力

url
http://{sso-server主机地址}/sso/pushS

接收参数:

参数是否必填说明
msgType消息类型,此处填 signout
loginId账号id
client客户端标识,可不填,代表是一个匿名应用
deviceId客户端设备 id
timestamp当前时间戳,13位
nonce随机字符串
sign签名,生成算法示例:md5( client={client值}&deviceId={设备id}&msgType={signout}&nonce={随机字符串}&loginId={loginId}&timestamp={13位时间戳}&key={secretkey秘钥} )

返回值示例:

js
{
  "code": 200,   // 返回 200=成功,500=失败
  "msg": "ok",
  "data": null
}

2、sso-client 端内置消息处理器

2.1、logoutCall(单点注销回调)

作用:接收来自 sso-server 的单点注销回调通知

url
http://{sso-client主机地址}/sso/pushC

接收参数:

参数是否必填说明
msgType消息类型,此处填 logoutCall
loginId账号id
deviceId客户端设备 id
timestamp当前时间戳,13位
nonce随机字符串
sign签名,生成算法示例:md5( deviceId={设备id}&msgType={logoutCall}&nonce={随机字符串}&loginId={loginId}&timestamp={13位时间戳}&key={secretkey秘钥} )

返回值示例:

js
{
  "code": 200,   // 返回 200=成功,500=失败
  "msg": "单点注销回调成功",
  "data": null
}

3、认证中心自定义消息处理器

当然你也可以通过自定义消息处理器的方式,来扩展消息推送能力,这将非常有助于你完成一些应用与认证中心的自定义数据交互。

假设我们现在有如下需求:在 sso-client 获取 sso-server 端指定账号 id 的昵称、头像等信息,即:用户资料的拉取。

首先,我们需要在 sso-server 实现一个消息处理器:

java
@RestController
public class SsoServerController {

	// 配置SSO相关参数 
	@Autowired
	private void configSso(SaSsoServerTemplate ssoServerTemplate) {

		// 添加消息处理器:userinfo (获取用户资料) (用于为 client 端开放拉取数据的接口)
		ssoServerTemplate.messageHolder.addHandle("userinfo", (ssoTemplate, message) -> {
			System.out.println("收到消息:" + message);

			// 自定义返回结果(模拟)
			return SaResult.ok()
					.set("id", message.get("loginId"))
					.set("name", "LinXiaoYu")
					.set("sex", "女")
					.set("age", 18);
		});

	}

}

4、应用端调用消息推送接口获取数据

首先保证在配置文件里要配置上消息推送的具体地址

<!---------------------------- tabs:start ----------------------------> <!------------- tab:yaml 风格 ------------->
yaml
# sa-token配置 
sa-token:
    # sso-client 相关配置
    sso-client:
        # 应用标识
        client: sso-client3
        # sso-server 端主机地址
        server-url: http://sa-sso-server.com:9000
        # sso-server 端推送消息地址
		# 配置 server-url 后,框架可自动计算对应的 push-url 地址,也可以单独配置 push-url 地址,两者选其一即可
        # push-url: http://sa-sso-server.com:9000/sso/pushS
        # API 接口调用秘钥
        secret-key: SSO-C3-kQwIOrYvnXmSDkwEiFngrKidMcdrgKor
<!------------- tab:properties 风格 ------------->
properties
# sso-client 相关配置
# 应用标识
sa-token.sso-client.client=sso-client3
# sso-server 端主机地址
sa-token.sso-client.server-url=http://sa-sso-server.com:9000
# sso-server 端推送消息地址
# 配置 server-url 后,框架可自动计算对应的 push-url 地址,也可以单独配置 push-url 地址,两者选其一即可
sa-token.sso-client.push-url=http://sa-sso-server.com:9000/sso/pushS
# API 接口调用秘钥
sa-token.sso-client.secret-key=SSO-C3-kQwIOrYvnXmSDkwEiFngrKidMcdrgKor
<!---------------------------- tabs:end ---------------------------->

然后在需要拉取资料的地方:

java
// 查询我的账号信息:sso-client 前端 -> sso-client 后端 -> sso-server 后端
@RequestMapping("/sso/myInfo")
public Object myInfo() {
	// 如果尚未登录
	if( ! StpUtil.isLogin()) {
		return "尚未登录,无法获取";
	}

	// 获取本地 loginId
	Object loginId = StpUtil.getLoginId();

	// 构建消息对象 
	SaSsoMessage message = new SaSsoMessage();
	message.setType("userinfo");
	message.set("loginId", loginId);
	
	// 推送至 sso-server,并接收响应数据 
	SaResult result = SaSsoClientUtil.pushMessageAsSaResult(message);

	// 返回给前端
	return result;
}