基于阿里云函数计算实现的，从阿里云IDaaS同步到阿里云RAM的Sample应用
代码实现说明：
- 本程序仅用于演示如果实现账号推送同步
- 本程序仅实现账号创建及更新，按
username进行创建或更新，同时未实现账号删除- 本程序账号处理逻辑并不严谨，比如应当按
userId进行操作，本例中仅按username进行操作- 本程序中未对错误进行细分类处理，实际项目中应当细化错误处理逻辑和日志记录
- 本程序仅处理了账号全量推送、新增、更新，未处理状态变更等其他事件
- 本程序未处理用户在该应用的应用账号映射，也就是说配置了应用账号登录时可能遇到用户找不到的问题
Requirements:
- Java 1.8
- Maven 3 (Tested: Maven 3.5.2)
编译并打包:
$ mvn package编译后得到文件：
$ ll target/
.rw-r--r-- 3.6M * 22 Feb 19:10 java-fc-ram-sample-1.0-SNAPSHOT.jar参数配置清单：
| 参数 | 说明 |
|---|---|
| paramAccessKeyId | 有RAM访问权限的AccessKeyID |
| paramAccessKeySecret | 有RAM访问权限的AccessKeySecret |
| paramAppId | 应用ID |
| paramJwkUrl | 应用账户同步的"验签公钥端点" |
| paramJwkJson | "验签公钥端点"对应的JWK JSON |
| paramKey | 应用账户同步的"加解密钥" |
paramJwkUrl 和 paramJwkJson 只需要配置其中一项，建议配置 paramJwkJson 减少运行时访问网络依赖
通过实现 EventDataCallback 或通过 DefaultEventDataCallbackImpl 注册事件回调
@Override
protected ResponseObject innerHandleRequest(Context context, RequestObject requestObject) throws Exception {
final FunctionComputeLogger logger = context.getLogger();
final IAcsClient client = AliyunClientUtil.createAcsClient();
final EventDataRunner eventDataRunner = new EventDataRunner();
eventDataRunner.setEncryptKey(KEY_VALUE);
eventDataRunner.setJwkUrl(JWK_URL_VALUE);
eventDataRunner.setAppId(APP_ID_VALUE);
eventDataRunner.setSimpleLogger(new FcSimpleLogger(context.getLogger()));
final DefaultEventDataCallbackImpl defaultEventDataCallback = new DefaultEventDataCallbackImpl();
eventDataRunner.setEventDataCallback(defaultEventDataCallback);
// 注册用户推送回调
defaultEventDataCallback.registerUserPushCallback(new UserPushCallback() {
@Override
public EventDataResponse onUserPush(EventContext eventContext, UserInfo userInfo) {
syncUser(client, logger, userInfo);
return EventDataResponse.newSuccessEventDataResponse();
}
});
// 注册用户增量回调，注意这里只处理了用户创建和更新，根据实际需求可以 Override 需要的函数
defaultEventDataCallback.registerUserCallback(new UserCallback() {
@Override
public EventDataResponse onUserCreate(EventContext eventContext, UserInfo userInfo) {
syncUser(client, logger, userInfo);
return EventDataResponse.newSuccessEventDataResponse();
}
@Override
public EventDataResponse onUserUpdateInfo(EventContext eventContext, UserInfo userInfo) {
syncUser(client, logger, userInfo);
// 根据实际情况这里返回 SKIPPED, FAILED, NEED_RETRY 不同类型的响应结果
return EventDataResponse.newSuccessEventDataResponse();
}
});
return eventDataRunner.dispatchEventData(requestObject);
}
