Java Server limit

[Daniel Smith]

Greetings,
I am writing a Java Server application using ServerSocket and when a client is sending the app data that is greater then 512 characters the message received is missing the first 512 characters and displays the rest of the message. The only thing that this app does is print to the screen what was received by the client. Any help would be great on how do I fix this problem to display the entire message sent by the client.

[Stan James]

Hi, welcome to the ranch!

Could you post a short bit of code around sending and receiving data? I'm curious about what kinds of streams you set up and how you chunk your sends. I dimly recall there are some limits around some of the streams. Maybe seeing your code will trigger some answers.

Since you're on post #1 and haven't submitted code before, I'll point out the CODE button below the editor. It puts open & close tags into the editor. When you put your code inside these, it preserves your indentation.

Cheers!

[Daniel Smith]

Thank you for your reply. The code for the server and client is listed below.

<- Server code ->

  
 
import java.net.*;
import java.io.*;
 
public class myServer {
 
  public static void main(String args[])
  {
    int port;
    ServerSocket server_socket;
    BufferedReader input;
    PrintWriter output;
 
    try
    {
      port = Integer.parseInt(args[0]);
    }
    catch(Exception e)
    {
      System.out.println("port = 15001 (default)");
      port = 15001;
    }
 
    try
    {
      server_socket = new ServerSocket(port);
      System.out.println("Server waiting for client on port " + server_socket.getLocalPort());
 
      while(true)
      {
Socket socket = server_socket.accept();
    System.out.println("New connection accepted " + socket.getInetAddress() + ":" + socket.getPort());
 
input = new BufferedReader(new InputStreamReader(socket.getInputStream()));
output = new PrintWriter(socket.getOutputStream(), true);
 
String outputLine;
 
outputLine = "0000079<?xml version=\"1.0\"?>" +
"<TRANSACTION>" +
"<ERRORCODE>0</ERRORCODE>" +
"</TRANSACTION>";
 

try
{
  while(true)
  {
    String message = input.readLine();
 
    if(message == null) break;
 
    output.println(outputLine);
    System.out.println(message);
  }
}
catch(IOException e)
{
  System.out.println(e);
}
 
try
{
  output.close();
  socket.close();
  System.out.println("Connection closed by client");
}
catch(IOException e)
{
  System.out.println(e);
}
      }
    }
    catch(IOException e)
    {
      System.out.println(e);
    }
 
  }
 

<- Client code to send ->

 

import java.net.*;
import java.io.*;
 
public class myClient {
 
  public static void main(String[] args)
  {
    int port = 15001;
    String server = "<ip address>";
    Socket socket = null;
    String lineToBeSent;
    BufferedReader input = null;
    BufferedReader serverInput = null;
    PrintWriter output = null;
    int ERROR = 1;
 
    if(args.length == 2)
    {
      server = args[0];
 
      try
      {
port = Integer.parseInt(args[1]);
      }
      catch(Exception e)
      {
System.out.println("server port = 15001 (default)");
       port = 15001;
      }
 
      try
      {
socket = new Socket(server, port);
System.out.println("Connected with server " + socket.getInetAddress() + ":" + socket.getPort());
      } 
      catch(UnknownHostException e)
      {
System.out.println(e);
System.exit(ERROR);
      }
      catch(IOException e)
      {
System.out.println(e);
System.exit(ERROR);
      }
 
      try
      {
input = new BufferedReader(new InputStreamReader(System.in));
 
serverInput = new BufferedReader(new InputStreamReader(socket.getInputStream()));
output = new PrintWriter(socket.getOutputStream(), true);
 
  while(true)
{
  lineToBeSent = input.readLine();
System.out.println("[" + lineToBeSent + "]");
 
  if(lineToBeSent.equals(".")) break;
 
  output.println(lineToBeSent);
 
  System.out.println("Server Response = " + serverInput.readLine());
}
      }
      catch(IOException e)
      {
System.out.println(e);
System.exit(ERROR);
      }
 
      try
      {
input.close();
serverInput.close();
output.close();
  socket.close(); 
      }
      catch(IOException e)
      {
System.out.println(e);
      }
    }
  }
 
}
 

Thanks for your help. Hopefully I did this correctly. If not please let me know.

Thanks,
Dan

[Yuan Ye]

The code looks fine to me, what os are you using on Client and Server? You might want to check your os setting for console input.

[Daniel Smith]

Peter,
The OS that this is running on is HP-UX B.11.23 U 9000/800. When I perform a getReceiveBufferSize() it shows me ~32K. When I set the buffer size to ~60K, I still have the problem that I currently have. I am at a loss with this one. I do thank everyone for thier help.

Thanks,
Dan

[Daniel Smith]

Everyone, I am still having this issue. I was told that the System.in has a bug. The bug is that it only allows 512 characters at a time. Is this correct? If so, how can I get around this. Please, any help would be wonderful. I am stuck.

Thanks

[Daniel Smith]

I have just run the code on my Linux box and it ran fine. I am going to try and run the code on the SUN box I have at work. It seems that the code will not run correctly on the HP box. Any thoughts?

[Eddie Vanda]

Try using the "flush ()" method after sending 511 characters.