正则--解析换行

 

 

06:13:44.403UTC ERROR com.carcloud.server.actors.gb808.v1.Gb808V1Handler akka.tcp://[email protected]:2551/user/gb808-server/$iKjf mdc=[ticket-#: ] received tcp message decode Failed! rx-data=7E020000AE010005436739044600000000000C00030208828706756C57019C029E005519041210541801040000D6A0030200001404000000001504000000001604000000001702000018030000002504000000002B040000000030010431011A642F0457F9DA010201000001000043019D0208827906756B8C190412105416000135343336373339190412105416000400B70400000000320164B1040C040000B40100B6020000BA020002BD0D00000027000301000000000000000F7E
java.lang.IllegalArgumentException: Could not find matching case for 512
    at scodec.Attempt$Failure.require(Attempt.scala:122)
    at scodec.Attempt$Failure.require(Attempt.scala:108)
    at com.carcloud.protocol.tcp.gb808.Gb808Message$.apply(Gb808Message.scala:114)
    at com.carcloud.protocol.tcp.gb808.Gb808Message$.apply(Gb808Message.scala:96)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.$anonfun$decode$2(AbstractGb808V1Actor.scala:71)
    at scala.util.Try$.apply(Try.scala:213)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.decode(AbstractGb808V1Actor.scala:71)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.decode$(AbstractGb808V1Actor.scala:67)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.decode(AbstractGb808V1Actor.scala:115)
    at com.carcloud.protocol.tcp.TcpHandleActor.decode_raw$1(TcpActor.scala:297)
    at com.carcloud.protocol.tcp.TcpHandleActor.onReceiveRaw(TcpActor.scala:323)
    at com.carcloud.protocol.tcp.TcpHandleActor.onReceiveRaw$(TcpActor.scala:291)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.onReceiveRaw(AbstractGb808V1Actor.scala:115)
    at com.carcloud.protocol.tcp.TcpHandleActor$$anonfun$defaultReceive$1.applyOrElse(TcpActor.scala:188)
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
    at akka.actor.Actor.aroundReceive(Actor.scala:517)
    at akka.actor.Actor.aroundReceive$(Actor.scala:515)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.aroundReceive(AbstractGb808V1Actor.scala:115)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)
    at akka.actor.ActorCell.invoke(ActorCell.scala:557)
    at akka.dispatch.MailBox.processMailBox(MailBox.scala:258)
    at akka.dispatch.MailBox.run(MailBox.scala:225)
    at akka.dispatch.MailBox.exec(MailBox.scala:235)
    at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
06:13:45.416UTC ERROR com.carcloud.server.actors.gb808.v1.Gb808V1Handler akka.tcp://[email protected]:2551/user/gb808-server/$iKjf mdc=[ticket-#: ] received tcp message decode Failed! rx-data=7E020000AE010005436739044700000000000C000302088319067572630198026C005219041210542601040000D6A1030200001404000000001504000000001604000000001702000018030000002504000000002B040000000030010431011A652F0457F9D302010200000000003F0199020882F1067570F0190412105414000135343336373339190412105409000700B70400000000320164B1040C040000B40100B6020000BA020002BD0D00000018800400CD000000000000827E
java.lang.IllegalArgumentException: Could not find matching case for 512
    at scodec.Attempt$Failure.require(Attempt.scala:122)
    at scodec.Attempt$Failure.require(Attempt.scala:108)
    at com.carcloud.protocol.tcp.gb808.Gb808Message$.apply(Gb808Message.scala:114)
    at com.carcloud.protocol.tcp.gb808.Gb808Message$.apply(Gb808Message.scala:96)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.$anonfun$decode$2(AbstractGb808V1Actor.scala:71)
    at scala.util.Try$.apply(Try.scala:213)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.decode(AbstractGb808V1Actor.scala:71)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1Processor.decode$(AbstractGb808V1Actor.scala:67)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.decode(AbstractGb808V1Actor.scala:115)
    at com.carcloud.protocol.tcp.TcpHandleActor.decode_raw$1(TcpActor.scala:297)
    at com.carcloud.protocol.tcp.TcpHandleActor.onReceiveRaw(TcpActor.scala:323)
    at com.carcloud.protocol.tcp.TcpHandleActor.onReceiveRaw$(TcpActor.scala:291)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.onReceiveRaw(AbstractGb808V1Actor.scala:115)
    at com.carcloud.protocol.tcp.TcpHandleActor$$anonfun$defaultReceive$1.applyOrElse(TcpActor.scala:188)
    at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
    at akka.actor.Actor.aroundReceive(Actor.scala:517)
    at akka.actor.Actor.aroundReceive$(Actor.scala:515)
    at com.carcloud.protocol.tcp.gb808.AbstractGb808V1HandlerActor.aroundReceive(AbstractGb808V1Actor.scala:115)
    at akka.actor.ActorCell.receiveMessage(ActorCell.scala:588)
    at akka.actor.ActorCell.invoke(ActorCell.scala:557)
    at akka.dispatch.MailBox.processMailBox(MailBox.scala:258)
    at akka.dispatch.MailBox.run(MailBox.scala:225)
    at akka.dispatch.MailBox.exec(MailBox.scala:235)
    at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

 

 

需要解析 从   06:13:45.416UTC ERROR   到   下一个时间。

^\d{2}\:\d{2}\:\d{2}\.\d{3}UTC ERROR .*

 

发现 用 . 无法解析换行。

网上搜了下，换行可以用 [\s\S]  或者 [\d\D] 或 [\w\W]  来解决。

但是无法控制到哪里结束。有大神知道嘛....欢迎留言哦

logstash 解析日志有个配置是，匹配不到的记录可以归到上一条或者下一条。这个例子就可以用归到上一条来规避...

 

 

正则表达式30分钟入门教程

http://deerchao.net/tutorials/regex/regex.htm