金蝶Apusic分布式消息队列
不需要配置用户名密码
rabbitmq:enable: truehost: 192.168.1.233port: 5672
<!-- Spring Boot RabbitMQ 依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.1.18.RELEASE</version></dependency>
3 代码配置,“vhost”虚拟机名称需要登录MQ界面新建
通过在 ADMQ 代理上引入 AMQP 协议处理程序,为 ADMQ 带来了原生的 AMQP 协议支持。
@Beanpublic ConnectionFactory connectionFactory(){CachingConnectionFactory connectionFactory = new CachingConnectionFactory(host,port);connectionFactory.setVirtualHost("vhost");connectionFactory.setPublisherConfirms(true); //设置发送消息失败重试connectionFactory.setChannelCacheSize(100);//解决多线程发送消息return connectionFactory;}
Apusic内存数据缓存
redis:## Redis数据库索引(默认为0)database: 0## Redis服务器地址host: 192.168.1.9## Redis服务器连接端口port: 6359## Redis服务器连接密码(默认为空)ssl: false #启用SSL终端识别password: timeout: 5000msjedis:pool:## 连接池最大连接数(使用负值表示没有限制)max-active: 8## 连接池最大阻塞等待时间(使用负值表示没有限制)max-wait: -1ms## 连接池中的最大空闲连接max-idle: 8## 连接池中的最小空闲连接min-idle:
依赖包,其实还是springboot-redis那套
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><version>2.7.2</version><exclusions><exclusion><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId></exclusion></exclusions></dependency><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId></dependency>
执行LUA脚本问题,需要我们本地代码进行适配和改造
这个兼容性都比较差,需要反复测试
public static <T> T execute(StringRedisTemplate stringRedisTemplate,final RedisScript<T> script, final List<String> keys, final Object[] args) {return stringRedisTemplate.execute(new RedisCallback<T>() {@Overridepublic T doInRedis(RedisConnection connection) throws DataAccessException {Object nativeConnection = connection.getNativeConnection();// redis序列化key、value、lua脚本RedisSerializer keySerializer = stringRedisTemplate.getKeySerializer();RedisSerializer valueSerializer = stringRedisTemplate.getValueSerializer();RedisSerializer<String> stringSerializer = stringRedisTemplate.getStringSerializer();List<byte[]> keys_ByteArr = new ArrayList<byte[]>(keys.size());List<byte[]> args_ByteArr = new ArrayList<byte[]>(args.length);for (int i = 0; i < keys.size(); i++) {keys_ByteArr.add(keySerializer.serialize(keys.get(i)));}for (int j = 0; j < args.length; j++) {args_ByteArr.add(valueSerializer.serialize(args[j]));}byte[] scriptByte = stringSerializer.serialize(script.getScriptAsString());if (nativeConnection instanceof JedisCluster) {return (T) ((JedisCluster) nativeConnection).eval(scriptByte, keys_ByteArr, args_ByteArr);}// 单点else if (nativeConnection instanceof Jedis) {return (T) ((Jedis) nativeConnection).eval(scriptByte, keys_ByteArr, args_ByteArr);}// 单机模式return (T) ((Jedis) nativeConnection).eval(scriptByte, keys_ByteArr, args_ByteArr);}});}
人大金仓KingBaseES 数据库,底层其实是pgsql
<!--KingBase--><dependency><groupId>com.kingbase8</groupId><artifactId>kingbase8</artifactId><version>8.6.0</version></dependency>
手动下载驱动包,地址/qd/index.htm
2 配置数据库地址, 需要注意脚本方言为: helperDialect: postgresql
############## 数据源master:datasource:url: jdbc:kingbase8://192.168.1.9:54321/hoe_hospital?useUnicode=true&allowMultiQueries=true&characterEncoding=utf8&useSSL=falseusername: J7EUl2ZBPKM=password: Soxks8s/VLiHR9Jo0gssJg==driverClassName: com.kingbase8.DrivervalidationQuery: select 1testOnBorrow: truetestWhileIdle: true## mappers 多个接口时逗号隔开mapper:mappers: com.moan.hoe.base.config.mybatis.MyMappernot-empty: falseidentity: kingbase8pagehelper:page-size-zero: truehelperDialect: postgresqlreasonable: truesupportMethodsArguments: trueparams: count=countSql
SQL语法问题,需要在业务中慢慢排查,关键字和内置函数都不太友好
1> 当mysql某个字段的类型为 tinyint时,且长度为1,迁移到金仓时,自动转换为 true 或 false;(需要讲tinyint改为2,才可以保持一样的数值,对应类型为Integer);tbl_menu_element 修改 is_deleted 为booleantbl_menu 修改 is_disable 为boolean2> mysql FIELD()函数替换掉 decode()3> 数据库初始化大小写不区分,4> 别名不能加mysql自动生成斜单引号,中文别明不能加单引号;5> mysql的函数和存储过程无法直接兼容kingBaseES库6> mysql的group_concat函数 kingbaseEs——string_agg(expression,delimiter) 输入值连接成一个串,用定界符分隔7> 命名需要加 as 关键字;select name,或者t.name 关键字都不需要加`` 上单引号,否则报错 (2)传参数时,数据加是什么类型,参数就一定要相同,否则报错, boolean 不能写成"0"或者"1" 这种传参8> 实体类的自增主键问题,去掉 //@GeneratedValue(strategy = GenerationType.IDENTITY) 只需保留@ID注解,需要在插入的时候给ID主键赋值,去掉自增注解并未解决,需要升级mybaits-plus插件最新版本9> 自定义SQL函数或者存储过程都需要重写
要先创建模式,相当于创建数据库,跨库查询的话,一定把所有模式创建到主模式下,才可以进行跨库查询表,
登录web管理界面 , 新建源数据 ,需要配置参数的可以在后面加 如tinyntlisBit=false 可以区分boolean类型
主要是新建源 数据到目标数据,再创建一个任务,启动任务后去执行两边的数据对比和导入
服务器
操作系统是: 统信uos