/********************************* head of file Comm_Socket.java *********************************/
|
package sp_comm;
|
import java.io.IOException;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.DatagramPacket;
|
import java.net.DatagramSocket;
|
import java.net.InetAddress;
|
import java.net.InetSocketAddress;
|
import java.net.Socket;
|
import java.nio.ByteBuffer;
|
import java.util.Date;
|
|
import com.Com;
|
import com.ComFn;
|
|
import main.page_debug_inf;
|
/*************************************************************************************************/
|
public class Comm_Socket {
|
public String mDevIp = "127.0.0.1";
|
public int mPort = 1000;
|
Socket mSocket = null;
|
/*********************************************************************************************/
|
public Comm_Socket(String ip_addr, int port) {
|
mSocket = new Socket();
|
mDevIp = ip_addr;
|
mPort = port;
|
}
|
/*********************************************************************************************/
|
public void socketClose() {
|
try {
|
mSocket.close();
|
} catch (IOException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
}
|
/*********************************************************************************************/
|
static public boolean SocketUdpComm(int local_port, String dev_ip, int port, ByteBuffer bbf_tx,
|
ByteBuffer bbf_rx, page_debug_inf dt_debug_inf, boolean printdat) {
|
boolean comm_res = false;
|
DatagramSocket socket_udp = null;
|
try {
|
socket_udp = new DatagramSocket(local_port);
|
byte[] dat_tx = new byte[bbf_tx.limit()];
|
for(int n=0; n<dat_tx.length; n++) {
|
dat_tx[n] = bbf_tx.get();
|
}
|
if(true == printdat) {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S)
|
+ " IP:" + dev_ip + " port:" + port
|
+ " UDP TX: " + ComFn.bytesToHexString(dat_tx, dat_tx.length) + "\n");
|
} else {
|
dt_debug_inf.addDebugInf("******\n");
|
}
|
|
InetAddress address = InetAddress.getByName(dev_ip);
|
DatagramPacket packet = new DatagramPacket(dat_tx, dat_tx.length, address, port);
|
socket_udp.setSoTimeout(1000);
|
socket_udp.send(packet);
|
|
if(bbf_rx.capacity() > 0) {
|
byte[] buffer = new byte[1024];
|
DatagramPacket receiver = new DatagramPacket(buffer, buffer.length);
|
socket_udp.receive(receiver);
|
|
byte[] dat_rx = receiver.getData();
|
int rx_len = receiver.getLength();
|
bbf_rx.clear();
|
bbf_rx.put(dat_rx, 0, rx_len);
|
bbf_rx.flip();
|
|
if(bbf_rx.limit() > 0) {
|
comm_res = true;
|
}
|
if(true == printdat) {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S)
|
+ " UDP RX: " + ComFn.bytesToHexString(dat_rx, rx_len) + "\n");
|
} else {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " RX: ******\n");
|
}
|
}
|
} catch (Exception e) {
|
//e.printStackTrace();
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " " + e.toString() + "\n");
|
} finally {
|
socket_udp.close();
|
socket_udp = null;
|
}
|
|
return comm_res;
|
}
|
/*********************************************************************************************/
|
public boolean SocketComm(ByteBuffer bbf_tx, ByteBuffer bbf_rx,
|
page_debug_inf dt_debug_inf, boolean printdat) {
|
boolean comm_res = false;
|
bbf_rx.clear();
|
|
InputStream s_in = null;
|
OutputStream s_out = null;
|
try {
|
if(false == mSocket.isConnected()) {
|
mSocket.connect(new InetSocketAddress(mDevIp, mPort), 1000);
|
mSocket.setSoTimeout(500);
|
}
|
|
if(mSocket.isConnected()) {
|
s_in = mSocket.getInputStream();
|
s_out = mSocket.getOutputStream();
|
|
byte[] dat_tx = new byte[bbf_tx.limit()];
|
bbf_tx.position(0);
|
for(int n=0; n<dat_tx.length; n++) {
|
dat_tx[n] = bbf_tx.get();
|
}
|
|
if(true == printdat) {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S)
|
+ " TCP TX: " + ComFn.bytesToHexString(dat_tx, dat_tx.length) + "\n");
|
} else {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " TX: ******\n");
|
}
|
|
s_out.write(dat_tx);
|
s_out.flush();
|
/*
|
for(int n=0; n<100; n++) {
|
Thread.sleep(10);
|
int len1 = s_in.available();
|
if(len1 <= 0) {
|
continue;
|
}
|
|
Thread.sleep(10);
|
|
if(s_in.available() == len1) {
|
break;
|
}
|
}
|
*/
|
byte[] dat_rx = new byte[3000];//new byte[s_in.available()];
|
int read_len = s_in.read(dat_rx);
|
bbf_rx.clear();
|
bbf_rx.put(dat_rx, 0, read_len);
|
bbf_rx.flip();
|
|
if(bbf_rx.limit() > 0) {
|
comm_res = true;
|
}
|
if(true == printdat) {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S)
|
+ " TCP RX: " + ComFn.bytesToHexString(dat_rx, read_len) + "\n");
|
} else {
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " RX: ******\n");
|
}
|
}
|
} catch (IOException e) {
|
socketClose();
|
dt_debug_inf.addDebugInf(Com.get_DTF(new Date(), Com.DTF_YMDhms_S) + " " + e.toString() + "\n");
|
mSocket = new Socket();
|
}
|
|
return comm_res;
|
}
|
/*********************************************************************************************/
|
}
|
/********************************* end of file Comm_Socket.java **********************************/
|
