Need help in protocol buffer in client server using java

Question

I am new to google protocol buffer . I am writing a client server application where client send request object to server and server return response. Currently when i send object to server neither the server respond nor throw any exception. Probably it stuck on line Request request = Request.parseFrom(bytes); where Request and Response are my message classes generated by protocol buffer. My code samples are as follows ``` public class TCPServer { final static Logger logger = Logger.getLogger(TCPServer.class.getName()); static int PORT = 6789; public static void main(String argv[]) throws Exception { ServerSocket socket = new ServerSocket(PORT); Socket connectionSocket = null; while(true) { try{ connectionSocket = socket.accept(); }catch (IOException e) { System.out.println("Could not listen on port:" + PORT); System.exit(-1); } Thread thread = new Thread(new ServerConnection(connectionSocket)); thread.start(); } } } public class ServerConnection implements Runnable{ static final Logger…

Accepted Answer

It works by using writeDelimtedTo(outputStream) and parseDelimitedFrom(inputStream) instead of writeTo(outputStream) and parseFrom(inputStream). So by putting the following code on server and client sides the program works.

Server side:

```
        InputStream input = connectionSocket.getInputStream();
        OutputStream output = connectionSocket.getOutputStream();

Request request = null;

while ((request = Request.parseDelimitedFrom(input)) != null) {
            System.out.println(request.toString());

}
```

Client side:

```
        Socket clientSocket = client.openConnection(HOST_NAME, PORT);

Request request = getRequest();

OutputStream output = clientSocket.getOutputStream();
         InputStream input = clientSocket.getInputStream();

request.writeDelimitedTo(output);
```

Need help in protocol buffer in client server using java

Solution

Problem

Related problems