首页 诗词 字典 板报 句子 名言 友答 励志 学校 网站地图
当前位置: 首页 > 教程频道 > JAVA > J2SE开发 >

寻求简单通讯的例子,该怎么解决

2012-03-15 
寻求简单通讯的例子要求tcp/ip同步短连接即:客户端发送信息时连接,得到服务响应(信息的返回,问题的回答等

寻求简单通讯的例子



要求tcp/ip同步短连接
即:
          客户端发送信息时连接,得到服务响应(信息的返回,问题的回答等等)客户端中止连接。
再发送时重新连接。


-----------------告急--------------

[解决办法]
服务端:

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class SimpleTestServer {
public static void main(String[] args) {
try {
ServerSocket ssocket = new ServerSocket(2000);
//port
while (true) {
Socket socket = ssocket.accept();
socket.setSoTimeout(0);
DataInputStream dataIn = new DataInputStream(socket
.getInputStream());
byte[] readBytes = new byte[1000];
int length = dataIn.read(readBytes);
if (length == -1) {
break;
}
/**
* 处理请求,比如打印收到的信息。
*/
System.out.println(new String(readBytes,0,length));
/**
* 构造应答信息
*/
byte[] reply = new byte[] { 'r ', 'e ', 'p ', 'l ', 'y ' };
DataOutputStream dataOut = new DataOutputStream(socket
.getOutputStream());
/**
* 发送应答信息
*/
dataOut.write(reply);
dataOut.flush();
dataOut.close();
/**
* 关闭连接
*/
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

客户端:
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class SimpleTestClient {
public static void main(String[] args) {
try
{
Socket socket = new Socket( "127.0.0.1 ",2000);
//ip port
socket.setSoTimeout(0);
DataOutputStream dataOut = new DataOutputStream(socket
.getOutputStream());
byte[] requestBytes=new byte[]{ 'r ', 'e ', 'q ', 'u ', 'e ', 's ', 't '};
dataOut.write(requestBytes);
dataOut.flush();
DataInputStream dataIn = new DataInputStream(socket
.getInputStream());
byte[] readBytes = new byte[1000];
int length = dataIn.read(readBytes);
dataIn.close();
if(length==-1)
{
dataOut.close();
socket.close();
}
System.out.println(new String(readBytes,0,length));
dataOut.close();
socket.close();
}catch(IOException e)
{
e.printStackTrace();
}
}
}

热点排行