| | |
| | | |
| | | /** |
| | | * 绑定 socket |
| | | * |
| | | * @throws Exception 可能端口冲突 |
| | | */ |
| | | public void bind() throws Exception { |
| | |
| | | * 初始化接收线程 |
| | | */ |
| | | private void initReceiveThread() { |
| | | if(null!=receiveThread){ |
| | | if (null != receiveThread) { |
| | | return; |
| | | } |
| | | receiveThread = ThreadToolUtils.getInstance().newFixedThreadPool(1); |
| | |
| | | try { |
| | | client.onHandleResponse(); |
| | | } catch (Exception e) { |
| | | LogUtils.i("接收线程异常:"+e.getMessage()); |
| | | LogUtils.i("接收线程异常:" + e.getMessage()); |
| | | } |
| | | } |
| | | } |
| | |
| | | |
| | | /** |
| | | * 发送数据 |
| | | * |
| | | * @param ipAddress 目的的IP地址 |
| | | * @param port 端口 |
| | | * @param msg 发送数据 |
| | | * @param listener 发送回调 |
| | | * @param port 端口 |
| | | * @param msg 发送数据 |
| | | * @param listener 发送回调 |
| | | */ |
| | | public void sendMsg(String ipAddress,int port,byte[] msg, SendListener listener) { |
| | | sendMsg(ipAddress,port, msg, true, listener); |
| | | public void sendMsg(String ipAddress, int port, byte[] msg, SendListener listener) { |
| | | sendMsg(ipAddress, port, msg, true, listener); |
| | | } |
| | | |
| | | /** |
| | | * 发送数据 |
| | | * |
| | | * @param ipAddress 目的的IP地址 |
| | | * @param port 端口 |
| | | * @param msg 发送数据 |
| | | * @param port 端口 |
| | | * @param msg 发送数据 |
| | | */ |
| | | public void sendMsg(String ipAddress,int port,byte[] msg) { |
| | | sendMsg(ipAddress,port, msg, true, null); |
| | | public void sendMsg(String ipAddress, int port, byte[] msg) { |
| | | sendMsg(ipAddress, port, msg, true, null); |
| | | } |
| | | |
| | | /** |
| | | * 发送数据 |
| | | * @param ipAddress 目的IP地址 |
| | | * @param port 端口 |
| | | * @param msg 发送的数据 |
| | | * |
| | | * @param ipAddress 目的IP地址 |
| | | * @param port 端口 |
| | | * @param msg 发送的数据 |
| | | * @param isRefreshRetry 是否要重发 |
| | | * @param listener 发送回调 |
| | | * @param listener 发送回调 |
| | | */ |
| | | public void sendMsg(String ipAddress,int port, byte[] msg, boolean isRefreshRetry, SendListener listener) { |
| | | public void sendMsg(String ipAddress, int port, byte[] msg, boolean isRefreshRetry, SendListener listener) { |
| | | if (isRefreshRetry) { |
| | | //重置连接次数 |
| | | resendCount.set(0); |
| | |
| | | isOpenRetry.set(false); |
| | | sendMap.clear(); |
| | | receiveThread.shutdown(); |
| | | receiveThread=null; |
| | | receiveThread = null; |
| | | client.close(); |
| | | } |
| | | } |