admin管理员组

文章数量:817350

信创

1 TLQ8.0 简单的例子,发送MQ,然后收消息连接是一样的,要不断去拉取数据消费的

public static void main(String[] args) {//==发送消息的目的队列String queName = "lq";//==连接工厂类QueueConnectionFactory queueConnectionFactory = null;//==连接类QueueConnection queueConnection = null;//==会话类QueueSession queueSession = null;//==打开的队列Queue queue = null;//==生产者QueueSender queueSender = null;try {//==创建连接工厂对象,并设置服务器地址信息,如果应用和TLQ服务端不在同一台机器上,请使用实际的服务端IP和Port替代下方的127.0.0.1和10024queueConnectionFactory = new QueueConnectionFactory();queueConnectionFactory.setProperty("tmqiAddressList", "tlkq://10.10.10.8:10024");//==创建Connection和SessionqueueConnection = queueConnectionFactory.createQueueConnection();queueSession = queueConnection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);//==打开TLQ 队列和创建QueueSenderqueue = queueSession.createQueue(queName);queueSender = queueSession.createSender(queue);//==启动连接queueConnection.start();//==生成一个TEXT类型消息Message message = queueSession.createTextMessage("QueueSenderNoJNDI Message");System.out.println("发送消息...");queueSender.send(message);System.out.println("发送完成...");} catch (Exception jmse) {System.out.println("Exception oxxurred :" + jmse.toString());jmse.printStackTrace();} finally {try {if (queueSession != null) {//==关闭会话queueSession.close();}if (queueConnection != null) {//==关闭连接queueConnection.close();}} catch (Exception e) {System.out.println("退出时发生错误。");e.printStackTrace();}}}
tlclient.jar
TongJMS.jar<!-- 东方通包  依赖 --><dependency><groupId>com.tongtech.rds</groupId><artifactId>spring-boot-starter-rds</artifactId><version>1.2.1</version></dependency>

TongRDS内存数据库

 redis:## Redis数据库索引(默认为0)database: 0## Redis服务器地址host: 192.168.1.90## Redis服务器连接端口port: 6379## Redis服务器连接密码(默认为空)ssl: false #启用SSL终端识别password: timeout: 5000msjedis:pool:## 连接池最大连接数(使用负值表示没有限制)max-active: 8## 连接池最大阻塞等待时间(使用负值表示没有限制)max-wait: -1ms## 连接池中的最大空闲连接max-idle: 8## 连接池中的最小空闲连接min-idle:

依赖包修改,去掉redis自带的lettuce,

<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>

redis配置类里,增加一个配置项,实际上他们的RDS是用socket连接的,我这里直接使用springboot的配置去连接,也能连接成功,不过最开始有一个坑,序列化object对象存数据的时候,解析有问题,然后更新了他们提供的包,并且在安装RDS 、apps/etc/cfg.xml 文件里增加配置,开启二进制

<BinaryCompatible>true</BinaryCompatible>

    @Bean // redis连接public RedisConnectionFactory redisConnectionFactory() {JedisConnectionFactory cf = null;RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();redisStandaloneConfiguration.setHostName(host);redisStandaloneConfiguration.setPort(port);// redisStandaloneConfiguration.setPassword(RedisPassword.of(redisPasswd));cf = new JedisConnectionFactory(redisStandaloneConfiguration);cf.afterPropertiesSet();return cf;}

还有外需要修改,单个KEY最大值是200有时候存KEY变报错,KEY太长,需要修改1000等看需求

<BinaryCompatible>true</BinaryCompatible><Key>bytes,200</Key>

执行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);}});}

达梦dm 数据库


<!--dameng--><dependency><groupId>com.dameng</groupId><artifactId>dm-jdbc</artifactId><version>1.8</version></dependency>

官网对应下载包 /

对应JDK1.8版本

2 配置数据库地址, 需要注意脚本方言为: helperDialect: oracle, URL后面不能带任何参数,记得修改插件方言

############## 数据源
master:datasource:url: jdbc:dm://192.168.1.90:5236username: J7EUl2ZBPKM=password: Soxks8s/VLiHR9Jo0gssJg==driverClassName: dm.jdbc.driver.DmDrivervalidationQuery: select 1testOnBorrow: truetestWhileIdle: true
## mappers 多个接口时逗号隔开
mapper:mappers: com.moan.hoe.base.config.mybatis.MyMappernot-empty: falseidentity: oracle
pagehelper:page-size-zero: truehelperDialect: oraclereasonable: truesupportMethodsArguments: trueparams: count=countSql

在项目创建lib目录,引入包

代码中遇到的SQL语法问题, 这是大坑

达梦是基于Oracle数据库,不支持主键自增长,其提供了一种叫做"序列(sequence)"的机制生成主键。此时,GenerationType.SEQUENCE就可以作为主键生成策略

Mysql 实体类注解生成主键 @GeneratedValue(strategy = GenerationType.IDENTITY)

Oracle 实体类注解生成主键 @GeneratedValue(strategy = GenerationType.SEQUENCE)

两者都兼容的类型 @GeneratedValue(strategy = GenerationType.AUTO) 自增和赋值主键

1> 当mysql某个字段的类型为 tinyint时,且长度为1,迁移到达梦时,需要创建一个bool类型转换为 true 或 false; 否则需要在代码转化为boolean时,先转为byte再转为bollean

2> mysql group_concat()函数替换掉 达梦的 to_char(wm_concat());函数'

3> 数据库初始化模式名称必须大写,表名全部大写

4> (1) mysql的函数split_part 不兼容,需要替换成regexp_substr函数 (2) mysql的时间函数date()替换掉to_date()函数。

5> mysql的函数和存储过程无法直接兼容dm数据库,必须重新写

6> 传参数时,数据加是什么类型,参数就一定要相同,否则报错, boolean 不能写成"0"或者"1" 这种传参

7> 实体类的自增主键问题,去掉 //@GeneratedValue(strategy = GenerationType.IDENTITY) 只需保留@ID注意,在数据插入后,必须查询出主键值,否则实体对象ID是空值,需要升级mybaits-plus插件最新版本

8> DISTINCT 去熏关键字,在多个字段上 并且有排序,会查询失败

数据迁移, 用他们自己的,安装客户端,同步数据是从源MYSQL ==》 达梦数据库,修改创建模式,每个模式就是一个数据库实例

在项目里使用还必须是大写的SQL查询,然后查询结果需要转化成小写,因为有些封装是MAP格式,业务代码太多SQL改造难度就更大了,还有在实体类的时候,尽量写上实体表名和数据库名

@Table(name = "items_student", schema = "hoe_activity")

本文标签: 信创