我正在尝试使用 Java 将视频从另一台机器流式传输到服务器,对于初学者,我只是尝试使用原始套接字连接和字节流传输文件。然而,事情并没有以同样的方式出现。如果我以这种方式传输文件,我机器上的 3MB 文件最终会在服务器上变为 5MB。我正在用视频文件尝试这个,当我下载它时,生成的文件实际上是“播放”的,并且长度正确,但没有图像。代码如下:
客户端(流媒体):
public static void main(String[] args){
Socket sock = null;
try{
System.out.println("Connecting...");
sock = new Socket("server.com", 8080);
InputStream is = new FileInputStream(new File("Bear.wmv"));
byte[] bytes = new byte[1024];
OutputStream stream = sock.getOutputStream();
int count = is.read(bytes, 0, 1024);
while (count != -1){
stream.write(bytes, 0, 1024);
count = is.read(bytes, 0, 1024);
}
is.close();
stream.close();
sock.close();
}catch (Exception e){
e.printStackTrace();
}
}
服务器(接收方):
public static void main(String[] args){
ServerSocket sock = null;
try {
sock = new ServerSocket(8080);
} catch (IOException e) {
System.out.println("Could not instantiate socket:");
e.printStackTrace();
return;
}
Socket clientSock = null;
while(true){
try{
System.out.println("Waiting for connection...");
clientSock = sock.accept();
final Socket fin = clientSock;
System.out.println("Connection accepted");
System.out.println("Spawning thread...");
Thread trd = new Thread(new Runnable(){
public void run(){
try {
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Receiving video...");
File video = new File("test.wmv");
FileOutputStream fos = new FileOutputStream(video);
byte[] data = new byte[1024];
int count = fin.getInputStream().read(data, 0, 1024);
while (count != -1){
fos.write(data, 0, 1024);
count = fin.getInputStream().read(data, 0, 1024);
}
fos.close();
fin.close();
System.out.println("Done receiving");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}}
});
trd.start();
}catch(IOException e){
System.out.println("Could not accept");
e.printStackTrace();
}
}
}
有什么想法吗?提前致谢!
克里斯