明德科技
Post By：2006-1-17 17:20:00 [只看該作者]
現在的問題是，開啟GPRS客戶端后，可以向服務器端(java)發(fā)送一次數據，可是第二次就連接不上了，重起客戶端后，又可以發(fā)送。請問，這種現象問題主要出在什么地方啊？
服務端的主要代碼如下：
//Server.java
import java.io.*;
import java.net.*;
public class Server
{
public static void main(String[] args) throws IOException
{
boolean listening = true;
try
{
serverSocket = new ServerSocket(9624);
}
catch (IOException e)
{
System.err.println("錯誤");
System.exit(1);
}
while(listening)
{
new MultiServerThread(serverSocket.accept()).start();
}
serverSocket.close();
}
}
//MultiServerThread.java
import java.lang.*;
import java.net.*;
import java.io.*;
public class MultiServerThread extends Thread
{
private Socket socket = null;
public MultiServerThread(Socket socket)
{
this.socket = socket;
}
public void run()
{
try
{
PrintWriter out = null;
BufferedInputStream in = null;
out = new PrintWriter(socket.getOutputStream(), true);
in = new BufferedInputStream(socket.getInputStream());
byte[] buf = new byte[255];
int bytes_read = 0;
bytes_read = in.read(buf);
DataProcess dataProcess = new DataProcess(buf,bytes_read);
dataProcess.process();
out.print("OK");
out.flush();
out.close();
in.close();
socket.close();
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
//DataProcess.java 略
服務端的主要代碼如下：
//Server.java
import java.io.*;
import java.net.*;
public class Server
{
public static void main(String[] args) throws IOException
{
boolean listening = true;
try
{
serverSocket = new ServerSocket(9624);
}
catch (IOException e)
{
System.err.println("錯誤");
System.exit(1);
}
while(listening)
{
new MultiServerThread(serverSocket.accept()).start();
}
serverSocket.close();
}
}
//MultiServerThread.java
import java.lang.*;
import java.net.*;
import java.io.*;
public class MultiServerThread extends Thread
{
private Socket socket = null;
public MultiServerThread(Socket socket)
{
this.socket = socket;
}
public void run()
{
try
{
PrintWriter out = null;
BufferedInputStream in = null;
out = new PrintWriter(socket.getOutputStream(), true);
in = new BufferedInputStream(socket.getInputStream());
byte[] buf = new byte[255];
int bytes_read = 0;
bytes_read = in.read(buf);
DataProcess dataProcess = new DataProcess(buf,bytes_read);
dataProcess.process();
out.print("OK");
out.flush();
out.close();
in.close();
socket.close();
}
catch (IOException e)
{
e.printStackTrace();
}
}
}
//DataProcess.java 略
