AI 助理
备案控制台
开发者社区 数据库 文章 正文

JEESZ分布式框架--单点登录集成方案

2018-06-28 1639
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介：

JEESZ分布式框架单点登录集成方案

第一节：单点登录简介

第一步：了解单点登录

SSO主要特点是: SSO应用之间使用Web协议(如HTTPS) ，并且只有一个登录入口.

SSO的体系中有下面三种角色:

1) User(多个)

2) Web应用(多个)

3) SSO认证中心(一个)

SSO实现包含以下三个原则:

1) 所有的登录都在 SSO 认证中心进行。

2) SSO认证中心通过一些方法来告诉Web应用当前访问用户究竟是不是通过认证的用户.

3) SSO认证中心和所有的 Web 应用建立一种信任关系.

CAS的基本原理CAS(Central Authentication Service) 是 Yale 耶鲁大学发起的构建Web SSO的Java开源项目。

1.CAS术语解释:

SSO－Single Sign On单点登录

TGT－Ticket Granting Ticket 用户身份认证凭证

ST－Service Ticket服务许可凭证

TGC－Ticket Granting Cookie存放用户身份认证凭证的cookie.

第二步：了解单点登录体系结构

1) CAS Server负责完成对用户信息的认证，需要单独部署，CAS Server会处理用户名/密码等凭证(Credentials).

2) CAS Client部署在客户端，当有对本地Web应用受保护资源的访问请求，并且需要对请求方进行身份认证，重定向到CAS Server进行认证.

第三步：单点登录环境准备工作

1) cas-server-3.5.0-release.zip（CAS服务端）

2) cas-client-3.3.3-release.zip（CAS客户端）

3) apache-tomcat-7.0.40

4) cas-client-core-3.2.1.jar

5) cas-server-core-3.5.0.jar

6) cas-server-support-jdbc-3.5.0.jar

第二节：单点登录环境搭建与部署

第一步：环境部署

  1. 通过Java JDK生成证书三部曲

证书对于实现此单点登录非常之重要，证书是服务器端和客户端安全通信的凭证，本教程只是演示，所有用了JDK自带的证书生成工具keytool。

当然在实际项目中你可以到专门的证书认证中心购买证书。

中文官方网站：http://www.verisign.com/cn/

使用JDK自带的keytool生成证书

第一步生成证书:

keytool -genkey -alias mycacerts -keyalg RSA -keystore C:/common/keys/keycard

注意：输入相关信息用于生成证书.其中名字与姓氏这一最好写你的 域名，如果在单击测试你可以在C:WindowsSystem32driversetchosts文件中映射一个虚拟域名，

注意不要写IP。

第二步导出证书:

keytool -export -file C:/common/keys/keycard.crt -alias mycacerts -keystore C:/common/keys/keycard

第三步导入到JDK安装目录证书:

keytool -import -keystore C:/"Program Files"/Java/jdk1.6.0_32/jre/lib/security/cacerts -file C:/common/keys/keycard.crt -alias mycacerts

  1. 解压cas-server-3.5.0-release.zip文件，

在cas-server-3.5.0-releasecas-server-3.5.0modules目录下找到cas-server-webapp-3.5.0.war文件并命名为cas.war，并复制到在Tomcat 根目录的webapps目录下，

如下图：

  1. 修改host文件（C:WindowsSystem32driversetc）hosts文件中添加添加以下配置

127.0.0.1 jeesz.cn (配置自己的域名.)

注意：如果想在一台PC机上模拟这个单点登录，就必须域名重定向，如果是多台ＰＣ机，可以不配置此项，下文有用到jeesz.cn，可以用相应ＰＣ机的ＩＰ代替

  1. 修改Tomcat文件下的server.xml(apache-tomcat-7.0.40confserver.xml) 添加以下内容：

在server.xml文件中把

maxThreads="150" scheme="https" secure="true"

clientAuth="false" sslProtocol="TLS" />

修改成如下：

port="8443"

protocol="org.apache.coyote.http11.Http11Protocol"

maxThreads="150"

SSLEnabled="true"

scheme="https"

secure="true"

clientAuth="false"

sslProtocol="TLS"

keystoreFile="C:/common/keys/keycard"

keystorePass="xxxxxx "

ciphers="TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256,TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA,TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384,TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA,TLS_RSA_WITH_AES_128_CBC_SHA256,TLS_RSA_WITH_AES_128_CBC_SHA,TLS_RSA_WITH_AES_256_CBC_SHA256,TLS_RSA_WITH_AES_256_CBC_SHA"

/>

5.启动Tomcat服务，查看信息，（如果有报错，可以根据信息查找错误），打开浏览器，输入http://jeesz.cn:8080/cas如果出现以下界面，则代表CAS服务端配置成功。

注：这个是最简单的CAS服务，只要输入的用户名跟密码一样，就可以正常登陆，在我们实际开发中，这个验证因为跟数据库作比较，接下来，我们就配置数据库校验。

第二步：配置数据库验证

1.在apache-tomcat-7.0.2webappscasWEB-INF目录下找到deployerConfigContext.xml文件，找到如下代码：

添加下面代码：

2.增加数据源dataSource，

在deployerConfigContext.xml，（跟上面同一个文件）找到

，在下面添加如下代码：

com.mysql.jdbc.Driver

jdbc:mysql://127.0.0.1:3306/sso

root

3.数据库添加用户表及数据（这里用的mysql），比如在mysql数据库中有t_user表

4.增加jar包, cas-client-core-3.2.1.jar、cas-server-core-3.5.0.jar、cas-server-support-jdbc-3.5.0.jar包拷贝到apache-tomcat-7.0.2webappscasWEB-INFlib目录下。

5.重启Tomcat，打开浏览器，输入http://jeesz.cn:8080/，输入数据库里的用户名和密码，如果出现如下界面，则配置成功。

现在我们的CAS服务端已经配置好了，接下来，我们配置客户端

第三节：配置自己的Web工程（客户端）

1.在host文件下，添加如下代码：

127.0.0.1 www.sso1.com

127.0.0.1 www.sso2.com

注意：这个网址最好不要用互联网已经存在的域名，否则你将无法访问该地址。

如果想在一台PC机上模拟这个单点登录，就必须域名重定向，如果是多台ＰＣ机，可以不配置此项，下文有用到www.sso1.com，www.sso2.com，可以用相应ＰＣ机的ＩＰ代替

2.在Tomcat 根目录下创建一个sso1,sso2目录。如下如：

  1. 在自己的Web工程里加入cas-client-core.jar，commons-logging-1.1.jar，（解压cas-client-3.2.0-release.zip，在cas-client-3.2.0-release.zipcas-client-3.2.0modules，找到该JAR包）

分别加入到sso1,sso2工程的lib里。

4.修改sso1下的web.xml。添加如下代码：

org.jasig.cas.client.session.SingleSignOutHttpSessionListener

SingleSignOutFilter

org.jasig.cas.client.session.SingleSignOutFilter

SingleSignOutFilter

/*

CASValidationFilter

org.jasig.cas.client.validation.Cas20ProxyReceivingTicketValidationFilter

casServerUrlPrefix

https://jeesz.cn:8443/cas;

serverName

http://www.sso1.com;

useSession

true

exceptionOnValidationFailure

false

redirectAfterValidation

true

CASValidationFilter

/*

CASFilter

org.jasig.cas.client.authentication.AuthenticationFilter

casServerLoginUrl

https://jeesz.cn:8443/cas/login;

serverName

http://www.sso1.com;

CASFilter

/*

CASHttpServletRequestWrapperFilter

org.jasig.cas.client.util.HttpServletRequestWrapperFilter

CASHttpServletRequestWrapperFilter

/*

CASAssertionThreadLocalFilter

org.jasig.cas.client.util.AssertionThreadLocalFilter

CASAssertionThreadLocalFilter

/*

SSO4InvokeContextFilter

com.common.core.busi.other.filter.SSO4InvokeContextFilter

SSO4InvokeContextFilter

/*

5.修改sso2下的web.xml。添加如下代码：

org.jasig.cas.client.session.SingleSignOutHttpSessionListener

SingleSignOutFilter

org.jasig.cas.client.session.SingleSignOutFilter

SingleSignOutFilter

/*

CASValidationFilter

org.jasig.cas.client.validation.Cas20ProxyReceivingTicketValidationFilter

casServerUrlPrefix

https://jeesz.cn:8443/cas;

serverName

http://www.sso2.com;

useSession

true

exceptionOnValidationFailure

false

redirectAfterValidation

true

CASValidationFilter

/*

CASFilter

org.jasig.cas.client.authentication.AuthenticationFilter

casServerLoginUrl

https://jeesz.cn:8443/cas/login;

serverName

http://www.sso2.com;

CASFilter

/*

CASHttpServletRequestWrapperFilter

org.jasig.cas.client.util.HttpServletRequestWrapperFilter

CASHttpServletRequestWrapperFilter

/*

CASAssertionThreadLocalFilter

org.jasig.cas.client.util.AssertionThreadLocalFilter

CASAssertionThreadLocalFilter

/*

SSO4InvokeContextFilter

com.common.web.filter.SSO4InvokeContextFilter

SSO4InvokeContextFilter

/*

6.编辑sso1,sso2 index.jsp页面,复制如下代码：

sso1 index.jsp:

这个是www.sso1.com

你好我是sso1页面:

<%= request.getRemoteUser()== null ? "null" : request.getRemoteUser() %>

Sso2 index.jsp:

这个是www.sso2.com

你好我是sso2页面:

<%= request.getRemoteUser()== null ? "null" : request.getRemoteUser() %>

7.通过eclipse发布到Tomcat服务器上去。找到Tomcat，webapps下的sso1,sso2文件夹，分别复制sso1和sso2下面的所有文件，找到Tomcat根目录下的sso1,sso2(就是我们前面步骤新建的目录)，在sso1,sso2下新建ROOT目录，把刚刚复制的文件粘贴。

配置Tomcat 下server.xml文件，加入如下代码：

8.重启Tomcat，打开浏览器输入网址：www.sso1.com:8080，输入用户名与密码，如果出现以下信息，则成功

在浏览器上输入www.sso1.com:8080，你会发现跳回到登录页面，不要担心。打开ticketGrantingTicketCookieGenerator.xml路径在apache-tomcat-7.0.40casROOTWEB-INFspring-configuration。找到p:cookieSecure="true"，将其修改为p:cookieSecure="false"，重启Tomcat，测试一下。

注：我们以上步骤返回的只有一个用户名，CAS服务器默认返回该信息。

第是节：修改单点登录默认界面

第一步：找到它自己的页面

打开cas工程，找到G:SoftWaretomcatapache-tomcat-7.0.2apache-tomcat-7.0.2webappscasWEB-INFviewjspdefault这个目录，将其复制一份重命名放在G:SoftWaretomcatapache-tomcat-7.0.2apache-tomcat-7.0.2webappscasWEB-INFviewjsp目录下，

第二步：修改默认登录页面

将其命名为mydefalut如下图：

然后将apache-tomcat-7.0.2webappscasWEB-INFclasses

目录下的default_views.properties复制一份，重命名为mydefault_views.properties。修改里面的内容，将所有里面的路径中的default改成mydefault。然后修改WEB-INF下的cas.properties将里面的cas.viewResolver.basename后面的值修改成mydefault_views即：

cas.viewResolver.basename=mydefault_views

如果要修改登录界面，只需要修改casLoginView.jsp即可。

第五节：单点登出配置

第一步：配置单点登录监听器和过滤器

1.Tomcat的sso1,sso2的工程里，在web.xml里分别添加一下代码：

org.jasig.cas.client.session.SingleSignOutHttpSessionListener

CAS Single Sign Out Filter

org.jasig.cas.client.session.SingleSignOutFilter

CAS Single Sign Out Filter

/*

注意：这些代码应该放在web.xml文件其他过滤器的最前面。

2.在sso1,sso2的index.jsp页面添加以下代码：

http://jeesz.cn:8080/logout">单点退出

3.重启Tomcat，访问http://jeesz.cn:8080/点击单点退出，如果成功，就会出现如下界面：

一般注销是跳到原项目的登录页面，所以我们需要对CAS做如下配置：

  1. 修改服务端cas-servlet.xml配置（apache-tomcat-7.0.40casROOTWEB-INF），找到

增加属性 p:followServiceRedirects="true"

2.修改客户端，sso1,sso2 index.jsp文件将原来的单点登出的URL修改成：

Sso1:http://jeesz.cn:8080/logout?service=http://www.sso1.com:8080

Sso2:http://jeesz.cn:8080/logout?service=http://www.sso2.com:8080

重启Tomcat，测试正常。

第六节：多项目集成单点登录配置

第一步：单点登录系统与其他项目集成

在WEB 项目中的WEB-INF目录下的web.xml文件，添加以下配置.

org.jasig.cas.client.session.SingleSignOutHttpSessionListener

SingleSignOutFilter

org.jasig.cas.client.session.SingleSignOutFilter

SingleSignOutFilter

/*

CASValidationFilter

org.jasig.cas.client.validation.Cas20ProxyReceivingTicketValidationFilter

casServerUrlPrefix

https://jeesz.cn:8443/cas;

serverName

http://www.sso3.com:6060;

useSession

true

exceptionOnValidationFailure

false

redirectAfterValidation

true

CASValidationFilter

/*

CASFilter

org.jasig.cas.client.authentication.AuthenticationFilter

casServerLoginUrl

https://jeesz.cn:8443/cas/login;

serverName

http:// www.sso3.com:6060

CASFilter

/*

CASHttpServletRequestWrapperFilter

org.jasig.cas.client.util.HttpServletRequestWrapperFilter

CASHttpServletRequestWrapperFilter

/*

CASAssertionThreadLocalFilter

org.jasig.cas.client.util.AssertionThreadLocalFilter

CASAssertionThreadLocalFilter

/*

SSO4InvokeContextFilter

com.common.web.filter.SSO4InvokeContextFilter

SSO4InvokeContextFilter

/*

当sso验证完成之后，客户端系统需要接收sso系统返回的结果时，需要定义一个过滤器获取返回结果，然后针对返回结果做相关处理.

注意：如果不需要做处理时，此处Filter也可以不用定义.

package com.common.web.filter;

import java.io.IOException;

import java.util.Date;

import javax.servlet.Filter;

import javax.servlet.FilterChain;

import javax.servlet.FilterConfig;

import javax.servlet.ServletException;

import javax.servlet.ServletRequest;

import javax.servlet.ServletResponse;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import javax.servlet.http.HttpSession;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.jasig.cas.client.util.AssertionHolder;

import org.springframework.web.context.WebApplicationContext;

import org.springframework.web.context.support.WebApplicationContextUtils;

import com.common.base.pbi.CommonConstants;

import com.common.base.util.DateUtil;

import com.common.base.util.IDUtil;

import com.common.base.util.IPUtil;

import com.common.base.util.UserUtil;

import com.common.core.busi.historylogin.manager.HistoryLoginManager;

import com.common.core.busi.login.manager.LoginManager;

import com.common.entity.common.AbstractEntity;

import com.common.entity.historylogin.HistoryLoginEntity;

import com.common.entity.user.UserEntity;

/**

  • 当成功登录SSO系统时将会返回登录的userid根据此userid建立session会话;
  • @ClassName: SessionFilter
  • @Description: TODO(这里用一句话描述这个类的作用)

*@authorjeesz

*@date2015-10-01

*

*/

public class SSO4InvokeContextFilter implements Filter{

private final static Log log = LogFactory.getLog(SSO4InvokeContextFilter.class);

private WebApplicationContext applicationContext;

public SSO4InvokeContextFilter() {

super();

}

/**

  • 过滤器注销时，触发此方法;

*/

public void destroy() {

//暂时不做任何处理;

}

/**

  • 根据用户id获取用户信息并且把用户信息放入session会话中;

*@Title: doFilter

  • @Description: TODO(这里用一句话描述这个方法的作用)
  • @Params
  • @throws

*/

public void doFilter(ServletRequest req, ServletResponse res, FilterChain chain) throws IOException, ServletException {

HttpServletRequest request = (HttpServletRequest)req;

HttpServletResponse response = (HttpServletResponse)res;

HttpSession session = request.getSession();

//从session中获取登陆用户;

Object userObject = session.getAttribute(CommonConstants.USER_INFO_SESSION);

if(userObject == null){

//获取用户名;

String userName = AssertionHolder.getAssertion().getPrincipal().getName();

LoginManager loginManager = applicationContext.getBean(LoginManager.class);

UserEntity userEntity = loginManager.loginByUserName(userName);

session.setAttribute(CommonConstants.USER_INFO_SESSION,userEntity);

session.setAttribute(CommonConstants.IS_SYSTEM_ADMIN,userEntity.getUserType()==1?true:false);

UserUtil.setLoginUserInfo(userEntity);

//根据用户名查询出用户信息，并放入session中;

log.info("UserName:["+userName +"]登陆成功，客户端IP地址为["+IPUtil.getIpAddr(request)+"]，登陆时间为["+DateUtil.dateToString(new Date())+"]");

//添加登录记录;

HistoryLoginEntity historyLoginEntity = new HistoryLoginEntity();

historyLoginEntity.setUserId(userName);

historyLoginEntity.setHid(IDUtil.generateId());

historyLoginEntity.setLoginCount("1");

setCommonValue(request,historyLoginEntity);

boolean hlBol = applicationContext.getBean(HistoryLoginManager.class).addLoginRecord(historyLoginEntity);

log.debug("登录历史记录["+(hlBol?"成功":"失败")+"].");

}

chain.doFilter(request, response);

}

/**

  • 设置公共属性;
  • @Title: setCommonValue
  • @Description: TODO(这里用一句话描述这个方法的作用)
  • @throws

*/

private void setCommonValue(HttpServletRequest request,AbstractEntity entity){

if(request != null){

//获取当前对象;

UserEntity userEntity = (UserEntity) request.getSession().getAttribute(CommonConstants.USER_INFO_SESSION);

if(entity !=null){

String currUser = userEntity.getUserId();

//设置创建人、创建日期、修改人、修改时间

entity.setCreatedBy(currUser);

entity.setModifiedBy(currUser);

entity.setCreationDate(DateUtil.getNowDate());

entity.setModifiedDate(DateUtil.getNowDate());

}

}

}

/**

  • 初始化Spring上下文;

*/

@Override

public void init(FilterConfig filterConfig) throws ServletException {

WebApplicationContext applicationContext = WebApplicationContextUtils.getWebApplicationContext(filterConfig.getServletContext());

this.applicationContext = applicationContext;

}

}

文章标签：
域名
云数据库 RDS MySQL 版
应用服务中间件
Java
数据库
数据安全/隐私保护
关系型数据库
关键词：
分布式框架
集成方案
分布式集成
单点登录集成
框架集成
花的鱼
目录
相关文章
奔跑的数据
|
1月前
|
数据采集 存储 数据可视化
分布式爬虫框架Scrapy-Redis实战指南
本文介绍如何使用Scrapy-Redis构建分布式爬虫系统，采集携程平台上热门城市的酒店价格与评价信息。通过代理IP、Cookie和User-Agent设置规避反爬策略，实现高效数据抓取。结合价格动态趋势分析，助力酒店业优化市场策略、提升服务质量。技术架构涵盖Scrapy-Redis核心调度、代理中间件及数据解析存储，提供完整的技术路线图与代码示例。
奔跑的数据
108 0
分布式爬虫框架Scrapy-Redis实战指南
蚝油菜花
|
1月前
|
人工智能 BI API
Dify-Plus：企业级AI管理核弹！开源方案吊打SaaS，额度+密钥+鉴权系统全面集成
Dify-Plus 是基于 Dify 二次开发的企业级增强版项目，新增用户额度、密钥管理、Web 登录鉴权等功能，优化权限管理，适合企业场景使用。
蚝油菜花
348 3
Dify-Plus：企业级AI管理核弹！开源方案吊打SaaS，额度+密钥+鉴权系统全面集成
Undoom
|
2月前
|
机器学习/深度学习 人工智能 自然语言处理
企业级API集成方案：基于阿里云函数计算调用DeepSeek全解析
DeepSeek R1 是一款先进的大规模深度学习模型，专为自然语言处理等复杂任务设计。它具备高效的架构、强大的泛化能力和优化的参数管理，适用于文本生成、智能问答、代码生成和数据分析等领域。阿里云平台提供了高性能计算资源、合规与数据安全、低延迟覆盖和成本效益等优势，支持用户便捷部署和调用 DeepSeek R1 模型，确保快速响应和稳定服务。通过阿里云百炼模型服务，用户可以轻松体验满血版 DeepSeek R1，并享受免费试用和灵活的API调用方式。
Undoom
265 12
一只笨鼠
|
4月前
|
存储 监控 数据可视化
常见的分布式定时任务调度框架
分布式定时任务调度框架用于在分布式系统中管理和调度定时任务，确保任务按预定时间和频率执行。其核心概念包括Job（任务）、Trigger（触发器）、Executor（执行器）和Scheduler（调度器）。这类框架应具备任务管理、任务监控、良好的可扩展性和高可用性等功能。常用的Java生态中的分布式任务调度框架有Quartz Scheduler、ElasticJob和XXL-JOB。
一只笨鼠
1641 66
蚝油菜花
|
3月前
|
人工智能 达摩院 并行计算
VideoRefer：阿里达摩院开源视频对象感知与推理框架，可集成 VLLM 提升其空间和时间理解能力
VideoRefer 是浙江大学与阿里达摩学院联合推出的视频对象感知与推理技术，支持细粒度视频对象理解、复杂关系分析及多模态交互，适用于视频剪辑、教育、安防等多个领域。
蚝油菜花
242 17
VideoRefer：阿里达摩院开源视频对象感知与推理框架，可集成 VLLM 提升其空间和时间理解能力
喵手
|
3月前
|
数据采集 人工智能 分布式计算
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
阿里云推出的MaxFrame是链接大数据与AI的分布式Python计算框架，提供类似Pandas的操作接口和分布式处理能力。本文从部署、功能验证到实际场景全面评测MaxFrame，涵盖分布式Pandas操作、大语言模型数据预处理及企业级应用。结果显示，MaxFrame在处理大规模数据时性能显著提升，代码兼容性强，适合从数据清洗到训练数据生成的全链路场景...
喵手
163 5
MaxFrame：链接大数据与AI的高效分布式计算框架深度评测与实践！
蓝易云
|
3月前
|
存储 缓存 Java
Java中的分布式缓存与Memcached集成实战
通过在Java项目中集成Memcached，可以显著提升系统的性能和响应速度。合理的缓存策略、分布式架构设计和异常处理机制是实现高效缓存的关键。希望本文提供的实战示例和优化建议能够帮助开发者更好地应用Memcached，实现高性能的分布式缓存解决方案。
蓝易云
75 9
warmhearted
|
3月前
|
人工智能 分布式计算 大数据
MaxFrame 产品评测：大数据与AI融合的Python分布式计算框架
MaxFrame是阿里云MaxCompute推出的自研Python分布式计算框架，支持大规模数据处理与AI应用。它提供类似Pandas的API，简化开发流程，并兼容多种机器学习库，加速模型训练前的数据准备。MaxFrame融合大数据和AI，提升效率、促进协作、增强创新能力。尽管初次配置稍显复杂，但其强大的功能集、性能优化及开放性使其成为现代企业与研究机构的理想选择。未来有望进一步简化使用门槛并加强社区建设。
warmhearted
243 7
技术自由圈/原疯狂创客圈
|
4月前
|
消息中间件 架构师 数据库
本地消息表事务：10Wqps 高并发分布式事务的 终极方案，大厂架构师的 必备方案
45岁资深架构师尼恩分享了一篇关于分布式事务的文章，详细解析了如何在10Wqps高并发场景下实现分布式事务。文章从传统单体架构到微服务架构下分布式事务的需求背景出发，介绍了Seata这一开源分布式事务解决方案及其AT和TCC两种模式。随后，文章深入探讨了经典ebay本地消息表方案，以及如何使用RocketMQ消息队列替代数据库表来提高性能和可靠性。尼恩还分享了如何结合延迟消息进行事务数据的定时对账，确保最终一致性。最后，尼恩强调了高端面试中需要准备“高大上”的答案，并提供了多个技术领域的深度学习资料，帮助读者提升技术水平，顺利通过面试。
技术自由圈/原疯狂创客圈
191 1
本地消息表事务：10Wqps 高并发分布式事务的 终极方案，大厂架构师的 必备方案
穿过生命散发芬芳
|
4月前
|
DataWorks 数据挖掘 大数据
方案实践测评 | DataWorks集成Hologres构建一站式高性能的OLAP数据分析
DataWorks在任务开发便捷性、任务运行速度、产品使用门槛等方面都表现出色。在数据处理场景方面仍有改进和扩展的空间，通过引入更多的智能技术、扩展数据源支持、优化任务调度和可视化功能以及提升团队协作效率，DataWorks将能够为企业提供更全面、更高效的数据处理解决方案。
穿过生命散发芬芳
207 11

热门文章

最新文章

  • 1
    RuoYi AI：1人搞定AI中台！开源全栈式AI开发平台，快速集成大模型+RAG+支付等模块
  • 2
    GitHub官方开源MCP服务！GitHub MCP Server：无缝集成GitHub API，实现Git流程完全自动化
  • 3
    体验AnalyticDB无感集成（Zero-ETL）下的一站式数据分析，完成任务可领取300社区积分兑换各种商城好礼！
  • 4
    DB-GPT V0.7.0版本更新：支持MCP协议、集成DeepSeek R1模型、GraphRAG检索链路增强、架构全面升级等
  • 5
    如何在 10 分钟内将 DeepSeek API 集成到您的应用程序
  • 6
    DeepSeek R1 集成难题完美解决：DeepSeek4j来帮你解决
  • 7
    通义灵码与魔搭Notebook深度集成：在线编码开箱即用，开发效率倍增
  • 8
    VMware ESXi 8.0U3e macOS Unlocker & OEM BIOS 集成驱动版，新增 12 款 I219 网卡驱动
  • 9
    1K star！这个开源项目让短信集成简单到离谱，开发效率直接翻倍！
  • 10
    通义灵码与魔搭 Notebook 深度集成：在线编码开箱即用，开发效率倍增
  • 1
    通用快照方案问题之通过Sleuth进行耗时分析和链路优化如何解决
    77
  • 2
    通用快照方案问题之通过Spring Cloud实现配置的自动更新如何解决
    121
  • 3
    面试题ES问题之Solr和Elasticsearch在分布式管理上如何解决
    73
  • 4
    Redis问题之Redis分布式锁与Zookeeper分布式锁有何不同
    107
  • 5
    Redis常见面试题（二）:redis分布式锁、redisson、主从一致性、Redlock红锁；Redis集群、主从复制，哨兵模式，分片集群；Redis为什么这么快，I/O多路复用模型
    3387
  • 6
    Spring Cloud Alibaba 集成分布式定时任务调度功能
    15392
  • 7
    分布式锁实现问题之数据库中的分布式锁有哪些缺点
    147
  • 8
    分布式篇问题之集群（Cluster）模式主控节点的高可用性问题如何解决
    64
  • 9
    现代数据库技术中的分布式一致性问题与解决方案探讨
    169
  • 10
    高并发架构设计三大利器：缓存、限流和降级问题之缓存的应对策略问题如何解决
    132

    • 相关课程

    更多
  • 事件总线EventBridge生态集成课程
  • 消息队列 RocketMQ 消息集成
  • Spring Boot+Vue.js+FastDFS实现分布式图片服务器
  • 基于Zookeeper、Dubbo构建互联网分布式基础架构
  • 分布式文件存储系统技术及实现
  • 分布式协调系统 Zookeeper 快速入门

    • 相关电子书

    更多
  • 阿里邮箱—安全高效集成
  • 集成智能接入网关APP：优化企业级移动办公网络
  • 云效助力企业集成安全到DevOps中

    • 相关实验场景

    更多
  • AnalyticDB无感集成（Zero-ETL）下的一站式数据分析
  • 体验PolarDB-X透明分布式
  • 每个IT人都想学的“Web应用上云经典架构”实战
  • 语言入门-1：环境构建
  • 前端开发基础1：前端开发环境的安装和配置
  • 阿里云IoT小程序应用开发和组件实践
    • 下一篇
    oss创建bucket