package com.ard.tianyu.netty;
|
|
import com.ard.tianyu.config.TyConfiguration;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.stereotype.Component;
|
import javax.annotation.PostConstruct;
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
@Slf4j
|
public class NettyConfig {
|
|
@Resource
|
private TyConfiguration tianyuConfiguration;
|
|
@Resource
|
private TyNettyTcpClient tyNettyTcpClient;
|
|
@PostConstruct
|
public void createTyConnect() {
|
try {
|
// 将Tcp访问的IP和地址加入到字典
|
Map<String,Object> mapParam =new HashMap<String, Object>();
|
mapParam.put("IP",tianyuConfiguration.getTcpserver());
|
mapParam.put("PORT",tianyuConfiguration.getTcpport());
|
|
//要么从数据库查询信息，要么从配置文件读取信息
|
List<Map<String, Object>> list = new ArrayList<>();
|
list.add(mapParam);
|
tyNettyTcpClient.initAllChannel(list);
|
}catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
