x2-300中通过jms提交到档案中心,一般我们只调用档案中心的接口,例如
post/archive/v1/style/tab/save
post请求档案中心的接口发送数据,但是这样只是修改了档案中心的档案数据,其他中心有相同的档案数据没有修改。例如商品档案,商品档案在每个中心都有自己的表需要同步。因为我们需要在每个中心定义相同的接口并在底层注册接口信息。
在底层包com.x3.bills.common.branch.core中可以定义拦截请求信息,例如
package com.x3.bills.common.branch.core.styletab; import com.x3.base.core.branch.Branch; import com.x3.base.core.branch.BranchEntity; import com.x3.base.core.branch.BranchUrlEntity; import com.x3.base.core.branch.IBranchService; import com.x3.base.core.jackson.JSON; import com.x3.base.core.util.ServiceUtil; import com.x3.bills.common.branch.core.styletab.request.ArchiveStyleTabRequest; import org.springframework.stereotype.Component; import java.util.List; /** * 拦截档案中心-款式标签保存接口,提交至各大数据中心 */ @Branch(url = "post/archive/v1/style/tab/save", tag = "拦截档案中心-款式标签保存接口,提交至各大数据中心") @Component public class StyleTabBaseBranchServiceImpl implements IBranchService { @Override public BranchEntity getNewDate(Object postData) { // 获取原请求参数 String request_json = JSON.toJSONString(postData); List<ArchiveStyleTabRequest> billsStyleList = JSON.parseArray(request_json, ArchiveStyleTabRequest.class); // 提交其他中心地址 BranchUrlEntity bi_url = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BI_ID+"/bi/archive/v1/style/tab/save"); BranchUrlEntity bill_url = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BILLS_ID+"/bill/archive/v1/style/tab/save"); BranchUrlEntity vipUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_VIPBIllS_ID+"/vip/bill/archive/v1/style/tab/save"); BranchUrlEntity biPojoUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_BI_POJO_ID+"/bi/pojo/archive/v1/style/tab/save"); BranchUrlEntity clickHoseUrl = new BranchUrlEntity("post/"+ ServiceUtil.SERVICE_CLICKHOUSE_ID+"/clickhouse/archive/v1/style/tab/save"); //添加实体 BranchEntity branchEntity = new BranchEntity(); branchEntity.add(bi_url); branchEntity.add(bill_url); branchEntity.add(vipUrl); branchEntity.add(biPojoUrl); branchEntity.add(clickHoseUrl); branchEntity.setData(billsStyleList); return branchEntity; } }
这是我定义的拦截配置,底层会将@Branch(url = "post/archive/v1/style/tab/save")配置的url请求拦截,并同步将请求信息发到其他中心地址,所以需要在其他中心实现对应的接口地址。
实现起来很麻烦,这种方案是否可以更好为其他自动同步的方案好一点呢?
字节(Byte)是计量单位,表示数据量多少,是计算机信息技术用于计量存储容量的一种计量单位,通常情况下一字节等于八位。字符(Character)计算机中使用的字母、数字、字和符号,比如'A'、'B'、'$'、'&'等。一般在英文...
(1).创建数组double[] myList = new double[size]; //推荐创建方式 double myList[] = new double[size];  ...
(1).java获取当前日期时间Date date = new Date(); System.out.println(date.toString());输出Fri Jul 02 10:29:55 CST 2021(2).java获取时间戳秒/毫秒D...
java匹配一个字符串在另外一个字符串中出现的次数,java正则start,java正则end// 正则 String pattern = "\\bgao\\b"; // 字符串 String content ...
(4).java lookingAt匹配字符串和java matches匹配字符串lookingAt不要求整个字符串全匹配,例如me和me_you都是匹配的,但是lookingAt从第一个字符串开始匹配,匹配失败了也不会继续匹配,意味着me和you_me是无法匹配的matches匹配字符串要求全部匹...
java 可变参数// 定义方法 public static int sum(int... number) { int result = 0; &nb...