我要评论socket发送数据需要注意的问题
这两天在写socket通信的时候遇到一个问题，在服务器端使用bufferedwriter.write()和bufferedwriter.flush()向客户端发送信息后，客户端使用bufferedreader.readline()怎么也读不到数据。
后来发现是因为没有在write之后创建新的行，所以客户端的readline()不能判断行结束，一直在等待服务器发送行结束符，就出现客户端接收不到数据的现象。
解决的方法
是在write()后newline()，再flush()客户端就可以了。
serversocket server = null;
try {
server = new serversocket(appprovider.port, 0);
bufferedreader in;
bufferedwriter out;
while (true) {
socket client = server.accept();
in = new bufferedreader(new inputstreamreader(client.getinputstream()));
out = new bufferedwriter(new outputstreamwriter(client.getoutputstream()));
out.flush();
try {
string request = in.readline();
string response = processmessage(request);
if (response != null) {
out.write(response);
out.newline();
out.flush();
}
} catch (exception e) {
e.printstacktrace();
}
in.close();
out.close();
client.close();
}
} catch (ioexception e) {
e.printstacktrace();
} finally {
if (server != null && !server.isclosed()) {
try {
server.close();
} catch (ioexception e) {
e.printstacktrace();
}
}
}java-socket上传 / 接收文件
socket上传文件
//测试示例
public void upsocket(){
//java中使用socket进行文件上传的基本流程如下所示：
//创建客户端socket对象并连接到服务器。可以通过指定ip地址和端口号来完成连接操作。
string serverip = "服务器ip"; // 设置服务器ip地址
int port = 8080; // 设置服务器监听的端口号
socket clientsocket = null;
inputstream inputstream = null;
outputstream outputstream = null;
try {
clientsocket = new socket(serverip, port);
//获取输入/输出流对象，分别用于读取要发送的文件内容和写入从服务器返回的数据。
string filepath = "要上传的文件路径";
file filetosend = new file(filepath);
if (!filetosend.exists()) {
throw new illegalargumentexception("指定的文件不存在！");
}
inputstream = new fileinputstream(filepath); // 设置要上传的文件路径
outputstream = clientsocket.getoutputstream();
//将文件内容逐段读取后写入输出流，直到文件结尾。
byte[] buffer = new byte[4096]; // 设置每次读取的字节大小
int bytesread;
while ((bytesread = inputstream.read(buffer)) != -1) {
outputstream.write(buffer, 0, bytesread);
}
outputstream.flush(); // 确保数据被全部写入输出流
} catch (ioexception e) {
e.printstacktrace();
}finally {
//关闭输入/输出流和socket连接。
try {
inputstream.close();
outputstream.close();
clientsocket.close();
} catch (ioexception e) {
e.printstacktrace();
}
}
}
socket接收文件
public static void main(string[] args) throws ioexception {
int portnumber = 8080;
serversocket serversocket = null;
inputstream inputstream = null;
fileoutputstream fileoutputstream = null;
try {
serversocket = new serversocket(portnumber);
system.out.println("正在监听端口" + portnumber + "...");
socket clientsocket = serversocket.accept();
system.out.println("客户端已连接！");
inputstream = clientsocket.getinputstream();
fileoutputstream = new fileoutputstream("d:\\test\\received_file.txt");
byte[] buffer = new byte[4096];
int bytesread;
while ((bytesread = inputstream.read(buffer)) != -1) {
fileoutputstream.write(buffer, 0, bytesread);
}
} catch (ioexception e) {
e.printstacktrace();
}finally {
fileoutputstream.close();
inputstream.close();
serversocket.close();
serversocket.close();
}
}
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持代码网。
发表评论