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和10024
queueConnectionFactory = new QueueConnectionFactory();
queueConnectionFactory.setProperty("tmqiAddressList", "tlkq://10.10.10.8:10024");
//==创建Connection和Session
queueConnection = queueConnectionFactory.createQueueConnection();
queueSession = queueConnection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
//==打开TLQ 队列和创建QueueSender
queue = 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: 5000ms
jedis:
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>() {
@Override
public 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>
官网对应下载包 https://eco.dameng.com/download/
对应JDK1.8版本
2 配置数据库地址， 需要注意脚本方言为: helperDialect: oracle, URL后面不能带任何参数,记得修改插件方言
############## 数据源
master:
datasource:
url: jdbc:dm://192.168.1.90:5236
username: J7EUl2ZBPKM=
password: Soxks8s/VLiHR9Jo0gssJg==
driverClassName: dm.jdbc.driver.DmDriver
validationQuery: select 1
testOnBorrow: true
testWhileIdle: true
## mappers 多个接口时逗号隔开
mapper:
mappers: com.moan.hoe.base.config.mybatis.MyMapper
not-empty: false
identity: oracle
pagehelper:
page-size-zero: true
helperDialect: oracle
reasonable: true
supportMethodsArguments: true
params: count=countSql在项目创建lib目录，引入包
代码中遇到的SQL语法问题， 这是大坑
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")
