java - Sierra Chart DTC Java 套接字连接空终止符

Question

我正在建立 Sierra Charts 和我的 Java 程序之间的集成，为此我正在使用他们的 DTC 协议(protocol)/框架，这使我能够(从我的 Java 程序)创建一个套接字连接，然后来回传递消息。但是，我目前陷入困境，因为他们要求我在每条消息后传递一个空终止符，这在 Java 世界中并不常见，让我感到困惑。为了让他们的套接字服务器处理我的消息，它需要包含“空终止符”(https://www.sierrachart.com/index.php?page=doc/DTCProtocol.php#JSONEncoding)

我已经联系了 Sierra Chart，但他们不是 Java 商店，也不知道有任何见解。

我已经包含了我的示例类，我正在使用 DTC 消息的 Json 编码。我所做的基础只是打开一个 Java 套接字，然后传递一个我已转换为 byte[] 的 Json 字符串并通过 BufferedOutputStream 写入套接字。然后我在等待回复。为了方便我的问题，我将我的 JSON 作为局部变量带入了字符串。我的问题是我无法破解我正在转换的 byte[] 或 String 的“空终止符”。我想知道是否有人可以阐明什么是“空终止符”；我的假设是 Sierra Chart Socket Server 正在运行 C 或 C++ 代码，这是它们的分隔符，我似乎无法掌握 Java 等价物。

import java.io.*;
import java.net.*;
import java.util.Date;


public class SierraChartSocketClient {

public SierraChartSocketClient() {
String testServerName = "127.0.0.1";
int port = 11099;

try{
      Socket socket = openSocket(testServerName, port);
      socket.setTcpNoDelay(true);

      String result = loginToSocketAndRequestData(socket);

      System.out.println(result);

socket.close();
}catch(Exception e){
e.printStackTrace();
}

}

private String loginToSocketAndRequestData(Socket socket) throws Exception{
byte nullByte = 0x00;
String loginRequestString = "    {\"Type\":1,\"Integer_1\":1,\"HeartbeatIntervalInSeconds\":60\", \"ClientName\": \"Sample Application\"}";

String marketDataRequestCL = "{\"Type\":101,\"RequestAction\":\"SUBSCRIBE\",\"SymbolID\":1,\"Symbol\":\"CLF8\", \"Exchange\":\"NYMEX\"}";
String heartBeat = "{\"Type\":3,\"CurrentDateTime \":\"" + (int) (System.currentTimeMillis() / 1000L) + "\" ";

try{
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));


BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(socket.getOutputStream());
System.out.println("Sending Over Login Request: " + new Date(System.currentTimeMillis()).toString());
bufferedOutputStream.write(loginRequestString.getBytes());
bufferedOutputStream.write(nullByte);
bufferedOutputStream.flush();


StringBuilder stringBuilder = new StringBuilder();
String str = bufferedReader.readLine();
System.out.println(str);
System.out.println("Received Login Response: " + new Date(System.currentTimeMillis()).toString());

bufferedOutputStream.write(heartBeat.getBytes());
bufferedOutputStream.flush();
System.out.println("Sending Heartbeat: " + new Date(System.currentTimeMillis()).toString());

bufferedOutputStream.write(marketDataRequestCL.getBytes("ISO-8859-1"));
bufferedOutputStream.write(nullByte);

while((str = bufferedReader.readLine()) != null){
stringBuilder.append(str + "\n");
System.out.println(str);
}


return null;
}catch (IOException e){
e.printStackTrace();
throw e;
}
}

private Socket openSocket(String server, int port) throws Exception{
Socket socket;

try{
InetAddress inteAddress = InetAddress.getByName(server);
SocketAddress socketAddress = new InetSocketAddress(inteAddress, port);

socket = new Socket();

int timeoutInMs = 45*1000; // 45 seconds
socket.connect(socketAddress, timeoutInMs);

return socket;

}catch (SocketTimeoutException e){
System.err.println("Timed out waiting for the socket.");
e.printStackTrace();
throw e;

}
}

public static void main(String[] args){
new SierraChartSocketClient();
}

}

另外我试过这个，(没用):

String loginRequestString = "{\"Type\":1,\"Integer_1\":1,\"HeartbeatIntervalInSeconds\":60\", \"ClientName\": \"Sample Application\"}";
byte[] loginRequestBytes = new byte[(loginRequestString.getBytes().length) + 1];
ByteBuffer bbuf = ByteBuffer.wrap(loginRequestBytes);
bbuf.put(loginRequestString.getBytes());

然后我试过这个，(没用):

int len = loginRequestString.length();
byte b[] = new byte[len + 1];
ByteBuffer bbufj = ByteBuffer.wrap(b);
enc.encode(CharBuffer.wrap(loginRequestString), bbufj, true);

我确信这是我所缺少的显而易见的东西。但是，我无法进行逻辑跳转，所以我希望有人能发现我的错误/错误/缺失的逻辑。任何帮助将不胜感激。

Answer 1

我碰巧也在尝试这个。

空终止符没有给出问题，你已经解决了。

问题是您使用的是 BufferedReader。这不起作用，您需要使用 BufferedInputStream。

Rgds