SpringSocial--第三方社交账号绑定

太过爱你忘了你带给我的痛 2024-02-19 17:31 47阅读 0赞

SpringSocial提供了表单登陆的账号和第三方账号绑定的功能，主要作用的控制类是social包下的**ConnectController**类。

ConnectController源码：

//用于社交账号绑定
    @Controller
    @RequestMapping("/connect")
    public class ConnectController implements InitializingBean {
    	
    	private final static Log logger = LogFactory.getLog(ConnectController.class);
    	
    	private final ConnectionFactoryLocator connectionFactoryLocator;
    	
    	private final ConnectionRepository connectionRepository;
    
    	private final MultiValueMap<Class<?>, ConnectInterceptor<?>> connectInterceptors = new LinkedMultiValueMap<Class<?>, ConnectInterceptor<?>>();
    
    	private final MultiValueMap<Class<?>, DisconnectInterceptor<?>> disconnectInterceptors = new LinkedMultiValueMap<Class<?>, DisconnectInterceptor<?>>();
    
    	private ConnectSupport connectSupport;
    	
    	private final UrlPathHelper urlPathHelper = new UrlPathHelper();
    	//试图路径
    	private String viewPath = "connect/";
        //session策略
    	private SessionStrategy sessionStrategy = new HttpSessionSessionStrategy();
    
    	private String applicationUrl = null;
    	...............................................
    
    	//获取绑定信息
    	@RequestMapping(method=RequestMethod.GET)
    	public String connectionStatus(NativeWebRequest request, Model model) {
    		setNoCache(request);
    		processFlash(request, model);
    		Map<String, List<Connection<?>>> connections = connectionRepository.findAllConnections();
    		model.addAttribute("providerIds", connectionFactoryLocator.registeredProviderIds());		
    		model.addAttribute("connectionMap", connections);
    		return connectView();
    	}
    	
    	//绑定
    	@RequestMapping(value="/{providerId}", method=RequestMethod.GET)
    	public String connectionStatus(@PathVariable String providerId, NativeWebRequest request, Model model) {
    		setNoCache(request);
    		processFlash(request, model);
    		List<Connection<?>> connections = connectionRepository.findConnections(providerId);
    		setNoCache(request);
    		if (connections.isEmpty()) {
    			return connectView(providerId); 
    		} else {
    			model.addAttribute("connections", connections);
    			return connectedView(providerId);			
    		}
    	}
    
    	
    	@RequestMapping(value="/{providerId}", method=RequestMethod.POST)
    	public RedirectView connect(@PathVariable String providerId, NativeWebRequest request) {
    		ConnectionFactory<?> connectionFactory = connectionFactoryLocator.getConnectionFactory(providerId);
    		MultiValueMap<String, String> parameters = new LinkedMultiValueMap<String, String>(); 
    		preConnect(connectionFactory, parameters, request);
    		try {
    			return new RedirectView(connectSupport.buildOAuthUrl(connectionFactory, request, parameters));
    		} catch (Exception e) {
    			sessionStrategy.setAttribute(request, PROVIDER_ERROR_ATTRIBUTE, e);
    			return connectionStatusRedirect(providerId, request);
    		}
    	}
         。。。。。。。。。。。。。。。。。。。。。
    	//解绑
    	@RequestMapping(value="/{providerId}", method=RequestMethod.DELETE)
    	public RedirectView removeConnections(@PathVariable String providerId, NativeWebRequest request) {
    		ConnectionFactory<?> connectionFactory = connectionFactoryLocator.getConnectionFactory(providerId);
    		preDisconnect(connectionFactory, request);
    		connectionRepository.removeConnections(providerId);
    		postDisconnect(connectionFactory, request);
    		return connectionStatusRedirect(providerId, request);
    	}
        //解绑
    	@RequestMapping(value="/{providerId}/{providerUserId}", method=RequestMethod.DELETE)
    	public RedirectView removeConnection(@PathVariable String providerId, @PathVariable String providerUserId, NativeWebRequest request) {
    		ConnectionFactory<?> connectionFactory = connectionFactoryLocator.getConnectionFactory(providerId);
    		preDisconnect(connectionFactory, request);
    		connectionRepository.removeConnection(new ConnectionKey(providerId, providerUserId));
    		postDisconnect(connectionFactory, request);
    		return connectionStatusRedirect(providerId, request);
    	}
    
    	//绑定试图名称 如果没有配置/connect/status 报错 pagenoFound
    	protected String connectView() {
    		return getViewPath() + "status";
    	}
    	
    	//解绑试图名称 如果没有配置/connect/status 报错 pagenoFound
    	protected String connectView(String providerId) {
    		return getViewPath() + providerId + "Connect";		
    	}
    
    	/**
    	 * Returns the view name of a page to display for a provider when the user is connected to the provider.
    	 * Typically this page would allow the user to disconnect from the provider.
    	 * Defaults to "connect/{providerId}Connected". May be overridden to return a custom view name.
    	 * @param providerId the ID of the provider to display the connection status for.
         * @return the view name of a page to display when the user is connected to the provider
    	 */
    	protected String connectedView(String providerId) {
    		return getViewPath() + providerId + "Connected";		
    	}
    
    	。。。。。。。。。。。。。。。。。。。。。。。。。。。。。
    }

绑定之前一定要有一个已经登陆的用户信息。

![20190220222214690.png][]

绑定请求路径 ：/connect/providerId

查看当前用户绑定信息：

/conect

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70][]

调用绑定路径：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 2][]

查看绑定状态，ConnectController获取大数据后自动跳转到试图名称为 connect/status，如果项目中没有配置，则报错。提示没有找到这个页面。

/**
     * 社交账号绑定状态视图
     */
    @Component("connect/status")
    public class SpringConnectionStatusView extends AbstractView {
    
    	@Autowired
    	private ObjectMapper objectMapper;
    
    	/* (non-Javadoc)
    	 * @see org.springframework.web.servlet.view.AbstractView#renderMergedOutputModel(java.util.Map, javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
    	 */
    	@SuppressWarnings("unchecked")
    	@Override
    	protected void renderMergedOutputModel(Map<String, Object> model, HttpServletRequest request,
    			HttpServletResponse response) throws Exception {
    
    		Map<String, List<Connection<?>>> connections = (Map<String, List<Connection<?>>>) model.get("connectionMap");
    
    		Map<String, Boolean> result = new HashMap<>();
    		for (String key : connections.keySet()) {
    			result.put(key, CollectionUtils.isNotEmpty(connections.get(key)));
    		}
    
    		response.setContentType("application/json;charset=UTF-8");
    		response.getWriter().write(objectMapper.writeValueAsString(result));
    	}
    
    }

配置完成，则会看到如下页面信息。

绑定完成/解绑完成后会跳转到如下试图：

//绑定试图名称 如果没有配置/connect/status 报错 pagenoFound
    	protected String connectView() {
    		return getViewPath() + "status";
    	}
    	
    	//解绑试图名称 如果没有配置/connect/Connect 报错 pagenoFound
    	protected String connectView(String providerId) {
    		return getViewPath() + providerId + "Connect";		
    	}

则需要进行配置试图：

/**
     * 绑定结果视图
     */
    public class SpringConnectView extends AbstractView {
    
    	/*
    	 * (non-Javadoc)
    	 *
    	 * @see
    	 * org.springframework.web.servlet.view.AbstractView#renderMergedOutputModel
    	 * (java.util.Map, javax.servlet.http.HttpServletRequest,
    	 * javax.servlet.http.HttpServletResponse)
    	 */
    	@Override
    	protected void renderMergedOutputModel(Map<String, Object> model, HttpServletRequest request,
    			HttpServletResponse response) throws Exception {
    
    		response.setContentType("text/html;charset=UTF-8");
    		if (model.get("connections") == null) {
    			response.getWriter().write("<h3>解绑成功</h3>");
    		} else {
    			response.getWriter().write("<h3>绑定成功</h3>");
    		}
    
    	}
    
    }

注入到Spring中：

@Bean({"connect/weixinConnect", "connect/weixinConnected"})
    @ConditionalOnMissingBean(name = "weixinConnectedView")
    public View weixinConnectedView() {
    		return new SpringConnectView();
    }

QQ等第三方社交账号一样，需要注意的是providerId不一样。如微信绑定是/connect/weixin，QQ：/connect/qq；微博：/connect/weibo等等

[20190220222214690.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/69c2b71f04ff4fa3a84a970fe4d1277c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/d2d4f7621b5d46598d12213398d9f24a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/356583c2a79e4487b7f4932c83f0ac4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/ea75952465644e0d8fe39a2191954513.png