EGTS receiver server realization writen on Go.
Library for implementation EGTS protocol that parsing binary packag based on GOST R 54619 - 2011 and Order No. 285 of the Ministry of Transport of Russia dated July 31, 2012. Describe fields you can find in these documents.
More information you can read in article (Russian).
Server save all navigation data from EGTS_SR_POS_DATA section. If packet have several records with
EGTS_SR_POS_DATA section, it saves all of them.
Storage for data realized as plugins. Any plugin must have [store] section in configure file.
Plugin interface will be described below.
If configure file has't section for a plugin ([store]), then packet will be print to stdout.
git clone https://github.com/kuznetsovin/egts-protocol
cd egts-protocol
make./bin/receiver -c config.yamlconfig.yaml - configure file
Build image
make dockerStart container:
docker run --name egts-receiver egts:latestStart container with custom port and config:
docker run --name egts-receiver -v ./configs:/etc/egts-receiver -p 6000:6000 egts:latestExample docker-compose:
version: '3'
services:
redis:
image: redis:latest
container_name: egts_redis
egts:
image: egts:latest
container_name: egts_receiver
ports:
- "6000:6000"
volumes:
- ./configs:/etc/egts-receviver/host: "127.0.0.1"
port: "6000"
con_live_sec: 10
log_level: "DEBUG"
storage:Parameters description:
- host - bind address
- port - bind port
- conn_ttl - if server not received data longer time in the parameter, then the connection is closed.
- log_level - logging level
- storage - section with storage configs. (see example)
Example for encoding packet:
package main
import (
"github.com/kuznetsovin/egts-protocol/libs/egts"
"log"
)
func main() {
pkg := egts.Package{
ProtocolVersion: 1,
SecurityKeyID: 0,
Prefix: "00",
Route: "0",
EncryptionAlg: "00",
Compression: "0",
Priority: "11",
HeaderLength: 11,
HeaderEncoding: 0,
FrameDataLength: 3,
PacketIdentifier: 137,
PacketType: egts.PtResponsePacket,
HeaderCheckSum: 74,
ServicesFrameData: &egts.PtResponse{
ResponsePacketID: 14357,
ProcessingResult: 0,
},
}
rawPkg, err := pkg.Encode()
if err != nil {
log.Fatal(err)
}
log.Println("Bytes packet: ", rawPkg)
}Example for decoding packet:
package main
import (
"github.com/kuznetsovin/egts-protocol/libs/egts"
"log"
)
func main() {
pkg := []byte{0x01, 0x00, 0x03, 0x0B, 0x00, 0x03, 0x00, 0x89, 0x00, 0x00, 0x4A, 0x15, 0x38, 0x00, 0x33, 0xE8}
result := egts.Package{}
state, err := result.Decode(pkg)
if err != nil {
log.Fatal(err)
}
log.Println("State: ", state)
log.Println("Package: ", result)
}That create a new plugin you must implement Connector interface:
type Connector interface {
// setup store connection
Init(map[string]string) error
// save to store method
Save(interface{ ToBytes() ([]byte, error) }) error
// close connection with store
Close() error
}All plugins available in store folder.
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent