Первая ласточка

[spasennyi_4ert]

Примерно так выглядят данные получаемые с биржи на erlang'е

s5@s5:~/erlang_fast$ erl -pa ./ebin
Erlang/OTP 17 [erts-6.1] [source] [64-bit] [smp:8:8] [async-threads:10] [kernel-poll:false]
Eshell V6.1  (abort with ^G)
1> application:start(erlang_fast).
ok
2> A = ["172.27.129.77","239.192.7.27","24027"].
["172.27.129.77","239.192.7.27","24027"]
3> erlang_fast_begin:start(A).
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305801},
                                      {<<"SendingTime">>,20140730174717392},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158966},
                                         {<<"MDEntrySize">>,2528},
                                         {<<"MDEntryTime">>,174709413},
                                         {<<"NumberOfOrders">>,329}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305802},
                                      {<<"SendingTime">>,20140730174718580},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"v">>},
                                         {<<"SecurityID">>,67227718},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,17087},
                                         {<<"MDEntrySize">>,811},
                                         {<<"MDEntryTime">>,174710613},
                                         {<<"NumberOfOrders">>,68}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305803},
                                      {<<"SendingTime">>,20140730174719611},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158967},
                                         {<<"MDEntrySize">>,2543},
                                         {<<"MDEntryTime">>,174711631},
                                         {<<"NumberOfOrders">>,330}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305804},
                                      {<<"SendingTime">>,20140730174721424},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,67225414},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,33714},
                                         {<<"MDEntrySize">>,526},
                                         {<<"MDEntryTime">>,174713457},
                                         {<<"NumberOfOrders">>,22}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305805},
                                      {<<"SendingTime">>,20140730174722877},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158968},
                                         {<<"MDEntrySize">>,2542},
                                         {<<"MDEntryTime">>,174714901},
                                         {<<"NumberOfOrders">>,329}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305806},
                                      {<<"SendingTime">>,20140730174724642},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158969},
                                         {<<"MDEntrySize">>,2546},
                                         {<<"MDEntryTime">>,174716666},
                                         {<<"NumberOfOrders">>,330}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305807},
                                      {<<"SendingTime">>,20140730174724846},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158970},
                                         {<<"MDEntrySize">>,2532},
                                         {<<"MDEntryTime">>,174716865},
                                         {<<"NumberOfOrders">>,329}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305808},
                                      {<<"SendingTime">>,20140730174725111},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158971},
                                         {<<"MDEntrySize">>,2533},
                                         {<<"MDEntryTime">>,174717139},
                                         {<<"NumberOfOrders">>,330}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305809},
                                      {<<"SendingTime">>,20140730174725627},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158972},
                                         {<<"MDEntrySize">>,2538},
                                         {<<"MDEntryTime">>,174717645},
                                         {<<"NumberOfOrders">>,331}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305810},
                                      {<<"SendingTime">>,20140730174726861},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158973},
                                         {<<"MDEntrySize">>,2537},
                                         {<<"MDEntryTime">>,174718881},
                                         {<<"NumberOfOrders">>,330}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305811},
                                      {<<"SendingTime">>,20140730174727783},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158974},
                                         {<<"MDEntrySize">>,2538},
                                         {<<"MDEntryTime">>,174719809},
                                         {<<"NumberOfOrders">>,331}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305812},
                                      {<<"SendingTime">>,20140730174728908},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"v">>},
                                         {<<"SecurityID">>,67227718},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,17088},
                                         {<<"MDEntrySize">>,821},
                                         {<<"MDEntryTime">>,174720926},
                                         {<<"NumberOfOrders">>,69}]]}]
<<"Reset">> []
<<"DefaultIncrementalRefreshMessage">> [{<<"ApplVerID">>,<<"8">>},
                                      {<<"MessageType">>,<<"X">>},
                                      {<<"SenderCompID">>,<<"RTS">>},
                                      {<<"MsgSeqNum">>,305813},
                                      {<<"SendingTime">>,20140730174728955},
                                      {<<"MDEntries">>,
                                       [[{<<"MDUpdateAction">>,0},
                                         {<<"MDEntryType">>,<<"w">>},
                                         {<<"SecurityID">>,64758598},
                                         {<<"SecurityIDSource">>,8},
                                         {<<"ExchangeTradingSessionID">>,
                                          4619},
                                         {<<"RptSeq">>,158975},
                                         {<<"MDEntrySize">>,2537},
                                         {<<"MDEntryTime">>,174720986},
                                         {<<"NumberOfOrders">>,330}]]}]