- xml - AJAX/Jquery XML 解析
- 具有多重继承的 XML 模式
- .net - 枚举序列化 Json 与 XML
- XML 简单类型、简单内容、复杂类型、复杂内容
我在两个不同的流上使用 PubSub,我们从一个流接收消息,运行一些逻辑,如果它符合特定条件,我们将它发布到第二个流。第二个流也在 goroutine 中接收。
现在,我有两个主要函数 HandleMessage
和 HandleRetry
,其中前者来自第一个流,第二个用于第二个流。
HandleMessage
的相关代码如下:
if c.handler.ShouldProcess(tx) {
err := c.handler.Process(tx)
if err != nil {
c.log.
WithError(err).
WithField("tx_hash", tx.TxHash.String()).
Error("failed to process")
retryMsg := RetryMessage{
Transaction: tx,
RemainingProcessingAttempts: c.config.MaxProcessingAttempts,
LastAttempt: time.Now(),
}
data, err := pubsub.EncodeMessage(retryMsg)
if err != nil {
c.log.WithError(err).Error("failed to convert retry msg to byte slice")
}
id, err := c.retryQueue.Publish(context.Background(), &pubsub.Message{Data: data})
if err != nil {
c.log.WithError(err).
WithField("id", id).
Error("failed to publish message to retry queue")
}
}
}
在 HandleRetry
中,函数以
retryTx := new(RetryMessage)
err := pubsub.DecodeMessage(msg.Data, retryTx)
if err != nil {
c.log.WithError(err).
Error("failed to decode message: not a retry tx")
msg.Ack()
return
}
对于由 HandleRetry
处理的 RetryQueue
-- 除了从 HandleMessage
发布的消息外没有其他输入
但是,我不断收到 gob 解码错误提示
level=error msg="解码消息失败:不是重试 tx"env=LOCAL error="gob:类型不匹配:没有字段匹配 RetryMessage 的编译解码器"
RetryMessage
看起来像这样
type RetryMessage struct {
Transaction *firehose.Transaction
RemainingProcessingAttempts int
LastAttempt time.Time
}
编解码函数如下
// EncodeMessage convert an arbitrary interface into a byte slice.
func EncodeMessage(data interface{}) ([]byte, error) {
var buf bytes.Buffer
enc := gob.NewEncoder(&buf)
err := enc.Encode(data)
if err != nil {
return nil, err
}
return buf.Bytes(), nil
}
// DecodeMessage decodes message data into the provided interface.
func DecodeMessage(data []byte, dest interface{}) error {
buf := bytes.NewBuffer(data)
dec := gob.NewDecoder(buf)
return dec.Decode(dest)
}
最佳答案
在 HandleMessage
中的这段代码中:
data, err := pubsub.EncodeMessage(retryMsg)
if err != nil {
c.log.WithError(err).Error("failed to convert retry msg to byte slice")
}
错误被忽略,发布消息的 data
字段填充了一个潜在的错误值。检查您是否在日志中看到“无法将重试消息转换为 byte slice ”。
关于采空区 : type mismatch: no fields matched compiling decoder - Golang,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55800616/
我正在尝试为匹配中的每个匹配呈现一些 HTML,但是,我不太确定 实际上是正确的。 更具体地说,我不确定我是否可以使用 v-bind:match='match'在与循环相同的元素上 v-for='ma
它具有看似简单的代码: method match(Any:U: |) { self.Str; nqp::getlexcaller('$/') = Nil } 但是,这是它的行为: (^3).matc
如果您想检查某项是否与正则表达式匹配,如果是,请打印第一组,您就可以了.. import re match = re.match("(\d+)g", "123g") if match is not N
以下两个查询的结果有差异吗? SELECT * FROM table1, table2 WHERE ( MATCH(table1.row1) AGAINST('searchstring' IN
我正在尝试为我的日志文件创建一个语法文件。它们采用以下格式: [time] LEVEL filepath:line - message 我的语法文件如下所示: :syn region logTime
String#match 和 Regexp#match 在匹配成功时返回一个 MatchData: "".match(//) # => # //.match("") # => # //.match(:
我的代码中有这个函数: func match(match: GKMatch, player playerID: String, didChangeState state: GKPlayerConnec
我对 match 和 case 之间的区别感到困惑。在 document ,其中提到match支持通用模式匹配。 > (define (m x) (match x [(list a
我在检查特定元素中的空 HTML 内容时遇到了问题。当我使用 someElement.trim().match("") 即使 HTML 内容为空,我有时也会得到 true。我改成了 someEleme
我正在尝试使用正则表达式查找包含特定词的两个词之间的所有内容,但是这些词是重复的,所以我没有得到我想要的匹配项。 例如,我想要“你好”和“再见”之间的所有内容,以便它们之间存在“苹果”一词: hell
我目前正在构建一个 PHP 脚本,它将在需要时响应 HTTP“304 Not Modified”。 (请参阅 question #2086712 了解我目前所做的事情)。 目前我回答以下问题: If-
给定以下 XML 10 我希望能够正确识别内部 的 s : result = subject.gsub(/]*>)/, '<') 解释: ]* # any number of charact
这个问题在这里已经有了答案: How to error handle 1004 Error with WorksheetFunction.VLookup? (3 个回答) 3年前关闭。 目标:查找输入
我已经尝试了好一阵子了,但是我似乎无法弄清楚这两者之间的区别。特别是,与数据数组有关的差异: PS C:>$myarray = "a", "ab", "abc" PS C:>$myarray -mat
我正在努力研究如何构建一个宏,让我可以将模式和结果以向量的形式传递给 core.match/match 。我希望能够做到这一点: (let [x {:a 1} patterns [[{:a
这个问题在这里已经有了答案: Reference - What does this regex mean? (1 个回答) 关闭 8 年前。 如果这看起来微不足道但只是为了理解正则表达式,请原谅我:
我的 MySQL 表中有大约 20 行,其 Title 列为 Elsewhere 并具有其他不同的列参数。 我目前正在使用这样的查询,因为我的大多数搜索(通过 PHP 文件)都需要我进行猜测。所以我使
当找到匹配时,我必须从字符串中删除单词 让我们看看 我的输入字符串是 “肯诺克斯路” 比赛表演中的单词表 街道 驾驶 道路 4. 车道 输出字符串应该是: KENOX 我正在使用 vb.net 作为此
我正在搜索以下形式的字符串模式: XXXAXXX # exactly 3 Xs, followed by a non-X, followed by 3Xs 所有的 X 必须是相同的字符,并且 A 不能
好吧,我是 gulp 和 sass 的新手,我正在努力让它发挥作用。我正确安装了所有东西,但我收到了这个愚蠢的错误。有解决办法吗? PS C:\Users\Bojan Kolano\Desktop\F
我是一名优秀的程序员,十分优秀!