| | |
|---|
| | | "kingdee-dbapi/nsqclient" |
|---|
| | | ) |
|---|
| | | |
|---|
| | | type QueryMsg struct { |
|---|
| | | type SqlQueryMsg struct { |
|---|
| | | Key string // 请求 |
|---|
| | | Command string |
|---|
| | | Success bool |
|---|
| | |
|---|
| | | Result []byte |
|---|
| | | } |
|---|
| | | |
|---|
| | | func QueryMsgHandle(msg []byte) error { |
|---|
| | | var query QueryMsg |
|---|
| | | func SqlQueryHandle(msg []byte) error { |
|---|
| | | var query SqlQueryMsg |
|---|
| | | |
|---|
| | | if err := json.Unmarshal(msg, &query); err != nil { |
|---|
| | | logger.Warn("解析请求失败, %s", err.Error()) |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | replyData, _ := json.Marshal(query) |
|---|
| | | ok := nsqclient.Produce(config.Options.ReplyTopic, replyData) |
|---|
| | | ok := nsqclient.Produce(config.Options.SqlReplyTopic, replyData) |
|---|
| | | logger.Warn("应答查询请求结果:%t, key:%s", ok, query.Key) |
|---|
| | | |
|---|
| | | return nil |
|---|
