利用串口传输数据，JavaGUI界面
串口方法类public class serialTool {
public static int flag=0;
static byte[] bytes = null;
public static List<String> findPort() {
// TODO Auto-generated method stub
Enumeration<CommPortIdentifier> portList = CommPortIdentifier.getPortIdentifiers();
List<String> portNameList = new ArrayList<>();
//将可用串口名添加到List并返回该List
while (portList.hasMoreElements()) {
String portName = portList.nextElement().getName();
portNameList.add(portName);
}
return portNameList;
}
public static SerialPort openPort(String commName, int btln) {
// TODO Auto-generated method stub
try {
//通过端口名识别端口
CommPortIdentifier portIdentifier = CommPortIdentifier.getPortIdentifier(commName);
//打开端口，并给端口名字和一个timeout（打开操作的超时时间）
CommPort commPort = portIdentifier.open(commName, 2000);
//判断是不是串口
if (commPort instanceof SerialPort) {
SerialPort serialPort = (SerialPort) commPort;
//设置一下串口的波特率等参数
serialPort.setSerialPortParams(btln, 8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
return serialPort;
}
}catch(NoSuchPortException e) {
e.printStackTrace();
JOptionPane.showMessageDialog(null, "错误：串口找不到！");
}catch(PortInUseException e1) {
e1.printStackTrace();
JOptionPane.showMessageDialog(null, "错误：串口已被占用！");
}catch(UnsupportedCommOperationException e2) {
e2.printStackTrace();
JOptionPane.showMessageDialog(null, "错误：操作不允许！");
}
return null;
}
public static void addListener(SerialPort port, SerialListener listener)throws TooManyListenersException {
// TODO Auto-generated method stub
//给串口添加监听器
port.addEventListener(listener);
//设置当有数据到达时唤醒监听接收线程
port.notifyOnDataAvailable(true);
//设置当通信中断时唤醒中断线程
port.notifyOnBreakInterrupt(true);
}
public static void closePort(SerialPort serialPort) {
// TODO Auto-generated method stub
if (serialPort != null) {
serialPort.close();
serialPort = null;
}
}
public static void sendToPort(SerialPort serialPort, String sendData) throws IOException{
// TODO Auto-generated method stub
OutputStream out = null;
out = serialPort.getOutputStream();
out.write(hexStringToByte(sendData));
out.flush();
out.close();
}
public static byte[] intToByteArray(int i) {
byte[] result = new byte[4];
//由高位到低位
result[0] = (byte)((i >> 24) & 0xFF);
result[1] = (byte)((i >> 16) & 0xFF);
result[2] = (byte)((i >> 8) & 0xFF);
result[3] = (byte)(i & 0xFF);
return result;
}
private static byte[] hexStringToByte(String hex) {
// TODO Auto-generated method stub
int len = (hex.length() / 2);
byte[] result = new byte[len];
char[] achar = hex.toCharArray();
for (int i = 0; i < len; i ) {
int pos = i * 2;
result[i] = (byte)( (toByte(achar[pos]) << 4 | toByte(achar[pos 1]))&0xff);
}
return result;
}
private static int toByte(char c) {
byte b = (byte) "0123456789abcdef".indexOf(c);
return b;
}
public static byte[] readFromPort(SerialPort serialPort)throws IOException {
// TODO Auto-generated method stub
InputStream in = null;
try {
in = serialPort.getInputStream();
while (true) {
// PacketLength为数据包长度
int PacketLength=10;
int newData=0;
byte[] bytes = new byte[PacketLength];
for(int i = 0; i < PacketLength; i ){
if( ( newData = in.read()) != -1){
bytes[i] = (byte)newData;
}else {
break;
}
}
return bytes;
}
} catch (IOException e) {
try {
throw e;
} catch (IOException e1) {
e1.printStackTrace();
}
} finally {
if (in != null) {
try {
in.close();
in = null;
} catch (IOException e) {
e.printStackTrace();
}
}
}
return null;
/*Timer timer=new Timer(true);
timer.schedule(new TimerTask() {
@Override
public void run() {
bytes=doit(serialPort);
}
}, 0,900);*/
}
protected static byte[] doit(SerialPort serialPort) {
// TODO Auto-generated method stub
InputStream in = null;
try {
in = serialPort.getInputStream();
while (true) {
// PacketLength为数据包长度
int PacketLength=10;
int newData=0;
byte[] bytes = new byte[PacketLength];
for(int i = 0; i < PacketLength; i ){
if( ( newData = in.read()) != -1){
bytes = intToByteArray(newData);
}
}
return bytes;
} /* int bufflenth = in.available(); //获取buffer里的数据长度
while (bufflenth != 0) {
bytes = new byte[bufflenth]; //初始化byte数组为buffer中数据的长度
in.read(bytes);
String str=printHexString(bytes);
bufflenth = in.available();
}*/
} catch (IOException e) {
try {
throw e;
} catch (IOException e1) {
e1.printStackTrace();
}
} finally {
if (in != null) {
try {
in.close();
in = null;
} catch (IOException e) {
e.printStackTrace();
}
}
}
return bytes;
//return bytes;
}
private static String printHexString(byte[] data) {
// TODO Auto-generated method stub
StringBuffer sbf=new StringBuffer();
for (int i = 0; i < data.length; i ) {
String hex = Integer.toHexString(data[i] & 0xFF);
if (hex.length() == 1) {
hex = '0' hex;
}
sbf.append(hex.toUpperCase() " ");
}
return sbf.toString().trim();
}
}
评论