6

我已经构建了一个微型 UDP/protobuf 发送器和接收器。我花了一上午的时间试图找出 protobuf 解码产生错误的原因，却发现是发送器 (Spoke.hs) 发送了不正确的数据。

用于unpack将 Lazy.ByteStrings 转换为 Network 包将发送的字符串的代码。我unpack在 Hoogle 中找到的。它可能不是我正在寻找的函数，但它的描述看起来很合适：“O(n) 将 ByteString 转换为字符串。”

Spoke.hs 产生以下输出：

chris@gigabyte:~/Dropbox/haskell-workspace/hub/dist/build/spoke$ ./spoke
45
45
["a","8","4a","6f","68","6e","20","44","6f","65","10","d2","9","1a","10","6a","64","6f","65","40","65","78","61","6d","70","6c","65","2e","63","6f","6d","22","c","a","8","35","35","35","2d","34","33","32","31","10","1"]

虽然wireshark向我显示数据包中的数据是：

0a:08:4a:6f:68:6e:20:44:6f:65:10:c3:92:09:1a:10:6a:64:6f:65:40:65:78:61:6d:70:6c:65:2e:63:6f:6d:22:0c:0a:08:35:35:35:2d:34:33:32:31:10

Spoke.hs 和 Wireshark 的长度 (45) 相同。

Wireshark 缺少最后一个字节（值 Ox01），并且中心值流不同（并且在 Wireshark 中大一个字节）。

"65","10","d2","9"在 Spoke.hs 与65:10:c3:92:09Wireshark 中。

由于 0x10 是 DLE，我感到很可能发生了一些转义，但我不知道为什么。

我对 Wireshark 有多年的信任，只有几十小时的 Haskell 经验，所以我认为是代码有问题。

任何建议表示赞赏。

-- Spoke.hs:

module Main where

import Data.Bits
import Network.Socket -- hiding (send, sendTo, recv, recvFrom)
-- import Network.Socket.ByteString
import Network.BSD
import Data.List
import qualified Data.ByteString.Lazy.Char8 as B
import Text.ProtocolBuffers.Header (defaultValue, uFromString)
import Text.ProtocolBuffers.WireMessage (messageGet, messagePut)
import Data.Char (ord, intToDigit)
import Numeric

import Data.Sequence ((><), fromList)

import AddressBookProtos.AddressBook
import AddressBookProtos.Person
import AddressBookProtos.Person.PhoneNumber
import AddressBookProtos.Person.PhoneType

data UDPHandle = 
     UDPHandle {udpSocket  :: Socket,
                udpAddress :: SockAddr}
opensocket :: HostName             -- ^ Remote hostname, or localhost
           -> String               -- ^ Port number or name
           -> IO UDPHandle         -- ^ Handle to use for logging
opensocket hostname port =
    do -- Look up the hostname and port.  Either raises an exception
       -- or returns a nonempty list.  First element in that list
       -- is supposed to be the best option.
       addrinfos <- getAddrInfo Nothing (Just hostname) (Just port)
       let serveraddr = head addrinfos

       -- Establish a socket for communication
       sock <- socket (addrFamily serveraddr) Datagram defaultProtocol

       -- Save off the socket, and server address in a handle
       return $ UDPHandle sock (addrAddress serveraddr)

john = Person {
  AddressBookProtos.Person.id = 1234,
  name = uFromString "John Doe",
  email = Just $ uFromString "jdoe@example.com",
  phone = fromList [
    PhoneNumber {
      number = uFromString "555-4321",
      type' = Just HOME
    }
  ]
}

johnStr = B.unpack (messagePut john)

charToHex x = showIntAtBase 16 intToDigit (ord x) ""

main::IO()
main = 
    do udpHandle <- opensocket "localhost" "4567"
       sent <- sendTo (udpSocket udpHandle) johnStr (udpAddress udpHandle)
       putStrLn $ show $ length johnStr
       putStrLn $ show sent
       putStrLn $ show $ map charToHex johnStr
       return ()
4

2 回答 2

3

我看到的 bytestring 包的文档将 unpack 列为将 a 转换ByteString为[Word8]，这与 a 不同String。我希望 和 之间存在一些字节差异ByteString，String因为StringUnicode 数据虽然ByteString只是一个有效的字节数组，但一开始unpack就不应该产生 a String。

因此，您可能在这里遇到了 Unicode 转换，或者至少当底层数据确实不是并且很少有好的结果时，某些东西将其解释为 Unicode。

于 2012-06-15T15:11:18.900 回答
1

我想你会想要toStringand fromStringfrom utf8-string而不是unpackand pack。这篇博文对我很有帮助。

于 2015-09-09T11:04:03.193 回答