串口通信之（一）获取传感器数据（modbus rtu master） |
您所在的位置：网站首页 › rtu通讯收到数据怎么处理 › 串口通信之（一）获取传感器数据（modbus rtu master） |
|
一天领导拿了几个传感器设备丢给我，给我把这些数据取到。
我一看，好家伙。这是要搞硬件了啊。那就搞他丫的。
可是，怎么搞是个问题。我是一头雾水。
还好，和传感器丢给我的，还有传感器厂家一起给的一些相关的资料(传感器的接线说明，调试软件，和java写的demo)
曾以为有文档和demo在手，就是让我上天，我也给走上一遭。可哪想到，即便是能上了天， 所遇到的问题，也能把磨到，上天的只剩下灵魂。
由于什么都不懂，真是困难重重。线，接起来不对。代码运行不进来。我想哭，怎么办？
于是我把着厂家技术支持这根稻草不放了。一个劲的问人家，都把人家问得烦了。线虽然接对了，可是代码还是运行起来。我再问，这下可好，人家是真烦了，被随便应付了。
可是，我知道了，要把这个传感的数据取到。需要用到485串口通信。于是我网上搜485串口通信。找到一份代码，而且能用。这可把我牛逼坏了，嘿嘿，果然没有什么是能难到程序员的。算是能成功取到了数据。
这里贴出这个程序的博客的地址。后面我也把我整理了一下的代码附上。 https://www.cnblogs.com/new-life/p/9345849.html 后来，我才知道这篇博客是写了一个相当于master程序，只能从传感器上获取到数据。
后来由于这个程序没有处理线程和粘包的问题，不太能满足需求，所以又需要改。
这时，已经知道了rtxxComm就是直接对串口进行操作的（读写数据），在上面的程序就是基于这个来写的。而rxtxComm中读写数据也是基于流来的。所以想到了结合netty，来写一个master。一下给出在代码没有处理粘包（写一个Decoder，在其中处理好一个完整的包，再传到handler就是了）
master.java public class Mater{ private String portName;//串口名 private int baudrate;//波特率 RxtxChannel channel; List data;//将设备返回的数据，解析后存于改list public Mater(String portName, int baudrate,List data) { this.data=data; this.portName = portName; this.baudrate = baudrate; } public void run(){ try { OioEventLoopGroup group = new OioEventLoopGroup(); Bootstrap b = new Bootstrap(); b.group(group) .channelFactory(new ChannelFactory() { public RxtxChannel newChannel() { return channel; } }) .handler(new ChannelInitializer() { @Override public void initChannel(RxtxChannel ch) throws Exception { ch.pipeline().addLast( new RxtxHandler() ); } }); channel = new RxtxChannel(); channel.config().setBaudrate(baudrate); channel.config().setDatabits(RxtxChannelConfig.Databits.DATABITS_8); channel.config().setParitybit(RxtxChannelConfig.Paritybit.EVEN); channel.config().setStopbits(RxtxChannelConfig.Stopbits.STOPBITS_1); ChannelFuture future = b.connect(new RxtxDeviceAddress(portName)).sync(); System.out.println("rxtx启动成功"); } catch (InterruptedException e) { e.printStackTrace(); } } public void writeAndFlush(String hexString) { String s = CRC16Util.crcDeal(hexString); System.out.println("手动发送数据："+s); byte[] bytes = ByteUtil.hexStringToBytes(s); ByteBuf buffer = channel.alloc().buffer(); ByteBuf byteBuf = buffer.writeBytes(bytes); channel.writeAndFlush(byteBuf); } public void inputCmd(){ Scanner sc=new Scanner(System.in); while (true){ String s = sc.nextLine(); writeAndFlush(s); } } //不断请求传感器数据 public void request() throws InterruptedException { String [] cmds = new String[]{"030300000002","020300020001","040300030001"}; for (int i = 0; i < cmds.length; i++) { Thread.sleep(500); writeAndFlush(cmds[i]); } } //程序入口 public static void main(String[] args) { Master master =new Master("COM3",9600,new ArrayList()); master.run(); master.request(); } } RxtxHandler.java public class RxtxHandler extends ChannelInboundHandlerAdapter { /** * 客户端接收到数据的回调 */ @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception{ byte[] read =new byte[in.readableBytes()]; in.readBytes(read); //将byte数据转成16进制的数据报文 //String packet = ByteUtil.BinaryToHexString(read).toUpperCase(); //可以对数据进行处理 //System.out.println(packet); } @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { cause.printStackTrace(); ctx.close(); } }
|
今日新闻 |
推荐新闻 |
| CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |