modbus4j例子的具體內(nèi)容

packagecom.modbus;importjava.nio.ByteBuffer;importcom.serotonin.modbus4j.ModbusFactory;importcom.serotonin.modbus4j.ModbusMaster;importcom.serotonin.modbus4j.exception.ModbusInitException;importcom.serotonin.modbus4j.exception.ModbusTransportException;importcom.serotonin.modbus4j.ip.IpParameters;importcom.serotonin.modbus4j.msg.ModbusRequest;importcom.serotonin.modbus4j.msg.ModbusResponse;importcom.serotonin.modbus4j.msg.ReadHoldingRegistersRequest;importcom.serotonin.modbus4j.msg.WriteRegistersRequest;importcom.serotonin.modbus4j.msg.WriteRegistersResponse;importcom.serotonin.util.queue.ByteQueue;/***modbus處理類*@author?**/publicclassModbusHandler{ staticModbusFactorymodbusFactory; static{ if(modbusFactory==null){ modbusFactory=newModbusFactory(); } } /** *得到WriteRegistersRequest * } /** *寫入 * *@paramip *@paramport *@paramslaveId *@paramstart *@paramvalues */ publicstaticintmodbusWTCP(Stringip,intport,intslaveId,intstart, short[]values){ ModbusMastertcpMaster=getTcpMaster(ip,port,slaveId); if(tcpMaster==null){System.out.println("tcpMasterisnull");return0;} tcpMaster=initTcpMaster(tcpMaster); WriteRegistersRequestrequest=getWriteRegistersRequest(slaveId,start,values); WriteRegistersResponseresponse=getWriteRegistersResponse(tcpMaster,request); if(response.isException()){ return0; }else{ return1; } } /** *初始化?tcpMaster * *@paramtcpMaster *@return */ publicstaticModbusMasterinitTcpMaster(ModbusMastertcpMaster){ if(tcpMaster==null)returnnull; try{ tcpMaster.init(); returntcpMaster; }catch(ModbusInitExceptione){ returnnull; } } /** *得到ModbusRequest * *@paramsalveId *@paramstart *@paramreadLenth *@paramtcpMaster */ publicstaticModbusRequestgetRequest(intsalveId,intstart, intreadLenth,ModbusMastertcpMaster){ ModbusRequestmodbusRequest=null; try{ modbusRequest=newReadHoldingRegistersRequest(salveId,start,readLenth); returnmodbusRequest; }catch(ModbusTransportExceptione){ e.printStackTrace(); returnnull; } } /** *得到ModbusResponse * *@paramsalveId *@paramstart *@paramreadLenth *@paramtcpMaster */ publicstaticModbusResponsegetModbusResponse(ModbusMastertcpMaster, ModbusRequestrequest){ ModbusResponsemodbusResponse=null; try{ modbusResponse=tcpMaster.send(request); returnmodbusResponse; }catch(ModbusTransportExceptione){ e.printStackTrace(); returnnull; } } /** *獲取設(shè)備數(shù)據(jù) *@paramip *信息機(jī)地址ip *@paramport *端口默認(rèn)端口502 *@paramsalveId *從站地址 *@paramstart *數(shù)據(jù)報(bào)文的起始位置 *@paramreadLenth *讀取的長(zhǎng)度 *@return結(jié)果 */ publicstaticByteQueuemodbusRTCP(Stringip,intport,intsalveId, intstart,intreadLenth){ ModbusMastertcpMaster=getTcpMaster(ip,port,salveId);//得到tcpMaster if(tcpMaster==null){System.out.println("tcpMasterisnull");returnnull; } returnmodbusRTCP0(ip,port,salveId,start,readLenth,tcpMaster); } /** *獲取tcpmaster * *@paramip *@paramport *@paramsalveId */ publicstaticModbusMastergetTcpMaster(Stringip,intport,intsalveId){ IpParametersparams=newIpParameters(); params.setHost(ip);//設(shè)置ip if(port==0)params.setPort(502);//設(shè)置端口，默認(rèn)為502 elseparams.setPort(port); ModbusMastertcpMaster=modbusFactory.createTcpMaster(params,true);//獲取ModbusMaster對(duì)象 returntcpMaster; } /** *modbus讀取 * *@paramip *@paramport *@paramsalveId *@paramstart *@paramreadLenth *@paramtcpMaster *@return */ publicstaticByteQueuemodbusRTCP0(Stringip,intport,intsalveId, intstart,intreadLenth,ModbusMastertcpMaster){ if(tcpMaster==null){System.out.println("tcpMasterisnull");returnnull;} tcpMaster=initTcpMaster(tcpMaster);//初始化tcpmaster if(tcpMaster==null){System.out.println("tcpMasterisnull");returnnull; } ModbusRequestmodbusRequest=getRequest(salveId,start,readLenth,tcpMaster);//得到requst對(duì)象 if(modbusRequest==null){System.out.println("requestisnull");returnnull;} ModbusResponseresponse=getModbusResponse(tcpMaster,modbusRequest);//發(fā)送請(qǐng)求，得到Response ByteQueuebyteQueue=newByteQueue(12); response.write(byteQueue); System.out.println("功能"+modbusRequest.getFunctionCode()); System.out.println("從站地址:"+modbusRequest.getSlaveId()); System.out.println("收到的響應(yīng)信息大小"+byteQueue.size()); System.out.println("收到的響應(yīng)信息小:"+byteQueue); returnbyteQueue; } /** *Convertbyte[]tohex *string.這里我們可以將byte轉(zhuǎn)換成int，然后利用Integer.toHexString(int)來(lái)轉(zhuǎn)換成16進(jìn)制字符串 *@paramsrcbyte[]data *@returnhexstring */ publicstaticStringbytesToHexString(byte[]src){ StringBuilderstringBuilder=newStringBuilder(""); if(src==null||src.length<=0){ returnnull; } for(inti=0;i<src.length;i++){ intv=src[i]&0xFF; Stringhv=Integer.toHexString(v); if(hv.length()<2){ stringBuilder.append(0); } stringBuilder.append(hv); } returnstringBuilder.toString(); } /** **************************************************** *起始位置15,響應(yīng)數(shù)據(jù)：從站|data包含的傳感器個(gè)數(shù)|datalength|data* **************************************************** * *@parambq */ publicstaticvoidansisByteQueue(ByteQueuebq){ byte[]result=bq.peekAll(); System.out.println("從站地址==="+result[0]); System.out.print