Java と C の間のソケットに問題があります。ソケットを作成してリッスンを開始する C プログラムがあります。Java クライアントは機能し、特定の状況下でソケットを開いて書き込み、読み取りを試みますが、これはブロックされます。
C プログラムのソケット部分は次のとおりです。
int sockfd, newsockfd, portno;
socklen_t clilen;
char buffer[256];
char wbuffer[256];
struct sockaddr_in serv_addr, cli_addr;
int n;
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if (sockfd < 0)
cout << "ERROR opening socket" << endl;
bzero((char *) &serv_addr, sizeof(serv_addr));
portno = 23456;
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(portno);
int on = 1;
if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0)
cout << "Couldn't set socket params!" << endl;
int so = bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
while(so < 0) {
cout << "ERROR on binding" << endl;
sleep(1);
so = bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr));
}
listen(sockfd,5);
clilen = sizeof(cli_addr);
newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
if (newsockfd < 0)
cout << "ERROR on accept" << endl;
bzero(buffer,256);
//cout << "Socket created!" << endl;
n = read(newsockfd,buffer,255);
if (n < 0)
cout << "Error reading from socket" << endl;
if (strcmp(buffer, "power\n") == 0) {
// Do stuff
strcpy(wbuffer, "off\n");
}
//sleep(1);
n = write(newsockfd,wbuffer,strlen(wbuffer));
if (n < 0)
cout << "ERROR writing to socket" << endl;
}
//cout << "message: " << buffer << endl;
close(newsockfd);
close(sockfd);
そして Java 側:
Socket socket3 = new Socket("localhost", 23456);
PrintWriter out3 = new PrintWriter(socket3.getOutputStream(), true);
BufferedReader in = new BufferedReader(new InputStreamReader(socket3.getInputStream()));
out3.write("power" + "\n");
//String status = in.readLine();
log.debug("Wrote power");
StringBuffer buffer = new StringBuffer();
while (true) {
int ch = in.read();
log.debug("in.read()");
if ((ch < 0) || (ch == '\n')) {
break;
}
buffer.append((char) ch);
}
String status = buffer.toString();
out3.close();
in.close();
socket3.close();
書き込みは機能し、デバッグを行いましたが、最後に行われたのは読み取り、特に in.read() です。
C テスト クライアントは出力を適切に読み取るため、Java 側で何かが欠けている可能性があります。
誰かがこれを機能させる方法についていくつかのアイデアを持っていることを願っています。私はどんな解決策にもオープンです。