javax.websocketclient:如何将大型二进制数据从clientendpoint发送到serverendp

Question

我正在尝试使用jetty构建一个服务器客户端应用程序。我已经设置了一个jetty服务器并配置了websocket。发送短信在客户端和服务器之间运行良好。但是如何从客户端端点发送二进制数据作为输入流。我找不到任何关于websocket客户端的片段。以下是我尝试过的

服务器端点：

@OnMessage
public void handleBinaryMessage(InputStream input, Session session) {
logger.info("onMessage::inputstream");
try {
byte[] buffer = new byte[2048];
try (OutputStream output = session.getBasicRemote().getSendStream())
{
int read;
while ((read = input.read(buffer)) >= 0)
output.write(buffer, 0, read);
}
} catch (IOException e) {
e.printStackTrace();
}

ClientEndpoint:

@OnOpen 
public void onOpen(Session s) throws IOException {
logger.info("Client Connected ... " + s.getId());
this.session=s;
session.getBasicRemote().sendText("Ping from client");
// size of the file 200~500MB
File source= new File("/tmp/Setup.exe");
try(InputStream input = new FileInputStream(source)) {

session.getAsyncRemote().sendObject(input);

}
}        

感谢提供的任何帮助

编辑：

我已经修改了clientendpoint和serverendpoint。试图将数据作为块发送，但zip文件是部分文件，有时甚至比源文件小得多。

源大小：1.5gb使用流从缓冲区写入数据后：20kb

@ClientEndpoint

private static void sendFileToRemote(File source) throws FileNotFoundException, IOException {
// TODO Auto-generated method stub
Session session=null;
final WsClient wc = new WsClient("ws://localhost:2714/events/","test");
session=wc.getSession();
try (
InputStream inputStream = new FileInputStream(source);
) {

byte[] chunk = new byte[102400];
int chunkLen = 0;
while ((chunkLen = inputStream.read(chunk)) != -1) {
session.getAsyncRemote().sendBinary(ByteBuffer.wrap(chunk, 0, chunkLen));
}
} catch (IOException ex) {
ex.printStackTrace();
}
}

@服务端点

@ServerEndpoint("/events/")
public class EventListener {
static Logger logger = Logger.getLogger(Initservice.class.getName());
private OutputStream os=null; 
@OnOpen
public void Init(Session session) throws FileNotFoundException {
this.user_session = session;
logger.info("onOpen:: server" + session.getId());     
this.os = new FileOutputStream(new File("/tmp/silicon_test.zip"));
logger.info("instantiate zip files");
}
@OnMessage
public void onMessage(Session session, ByteBuffer byteBuffer) throws IOException {
try {
os.write(byteBuffer.get());
} catch(Exception e) {
close();
logger.log(Level.SEVERE,"Exception occured in onMessage :: ", e);
throw e;
}
}
}

Answer 1

ServerEndpoint中的代码看起来应该可以正常工作，但在ClientEndpoint中，您只向ServerEndpoint发送文本数据，并且只能由配置为接收文本消息的服务器onMessage方法读取。

不应该使用session.getRemoteEndpoint().sendText(...)，而应该使用方法session.getRemoteEndpoint().sendBinary(...)。这将以二进制帧而不是文本帧发送数据，并且您将能够在服务器handleBinaryMessage方法中接收数据。

至于session.getAsyncRemote().sendObject(input)，为了实现这一点，您还需要提供Encoder.Binary或Encoder.BinaryStream，以便将对象作为二进制数据发送。

编辑：

WebSocket是一个基于消息的协议，您通过多个WebSocket消息从文件中发送数据。您可以使用session.getBasicRemote().sendBinary(ByteBuffer, boolean)发送部分消息，并在同一消息中发送所有数据。

或者您可以尝试类似这样的代码，它可能更简单。

try (InputStream inputStream = new FileInputStream(source))
{
try (OutputStream sendStream = session.getBasicRemote().getSendStream())
{
inputStream.transferTo(sendStream);
}
}