| | |
| | | public boolean isConncet = false; |
| | | private final Timer timer = new Timer(); |
| | | |
| | | |
| | | @Override |
| | | public void onCreate() { |
| | | super.onCreate(); |
| | |
| | | isAidl = aidl; |
| | | } |
| | | |
| | | public IpBean ipBean; |
| | | |
| | | /** |
| | | * 初始化EasySocket |
| | | */ |
| | | public void initEasySocket(boolean isCreate, SocketNet.CreateBack createBack) { |
| | | try { |
| | | this.createBack = createBack; |
| | | IpBean ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst(); |
| | | ipBean = BaseDaoSingleton.getInstance(MyApplication.myApplication).ipDao().findFirst(); |
| | | if (ipBean == null) { |
| | | ipBean = new IpBean(); |
| | | ipBean.setIp("dayuyanjiuyuan.top"); |
| | | ipBean.setPort(8888); |
| | | } |
| | | if (ipBean != null) { |
| | | try { |
| | | //处理当连接上IP后修改ip不生效问题 |
| | |
| | | .setSocketAddress(new SocketAddress(ip, port)) |
| | | // 定义消息协议,方便解决 socket黏包、分包的问题 |
| | | .setReaderProtocol(new ScoketMessageProtocol()) |
| | | .setMaxWriteBytes(1024) |
| | | .setMaxReadBytes(1024) |
| | | .setRequestTimeout(10 * 1000) |
| | | .setMaxWriteBytes(150) |
| | | .setMaxReadBytes(150) |
| | | .setRequestTimeout(5 * 1000) |
| | | .build(); |
| | | |
| | | // 初始化 |