所以,我有两个主题.
线程1管理客户端连接.(只有一个客户端和一个服务器)
我称之为我的服务器线程.
线程二管理向客户端发送消息.我称之为消息处理器线程.
线程1负责,除其他外,定期向客户端发送心跳.
在编程时我假设套接字不是线程安全的,但缓冲区是,并且只要我使用单独的缓冲区用于服务器和处理器线程我就没问题了.
我还假设"PrintWriter"类似于Java中的套接字缓冲区.
在这些假设下,我写了这个函数来发送心跳:
public void sendHeartBeat(){
logger.info("Sending a hearbeat!");
PrintWriter printWriter=null;
try {
printWriter = new PrintWriter(clientSocket.getOutputStream());
} catch (IOException e) {
logger.info(e.toString());
}
if(printWriter!=null){
printWriter.print("HEARTBEAT#");
printWriter.flush();
}
}
Run Code Online (Sandbox Code Playgroud)
另一个线程,"处理器"做了类似的事情:
printWriter=new PrintWriter(theServer.getClientSocket().getOutputStream());
Run Code Online (Sandbox Code Playgroud)
通过这种方式,每次我希望发送心跳时,我都会创建一个新的"缓冲区",而且我的消息永远不会被覆盖.
不幸的是,情况似乎并非如此.我收到一条消息来自管道:dsgdsbHEARTBEAT #sdg
这会导致稍后的核心转储.
这是我的问题:
1)套接字显然不是线程安全的,但是我从它们获得的PrintWriters是否安全?或者它只是返回相同的PrintWriter?
2)什么类似于Java中的套接字缓冲区?我该如何看待这个问题?
3)如何使这些线程不写入套接字上的相同缓冲区?