Socket通信最简单实例

服务器端代码

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class JabberServer {
public static final int port = 8080;

public static void main(String[] args) throws IOException {

ServerSocket serversocket = new ServerSocket(port);
try {
System.out.println("start:" + serversocket);
Socket socket = serversocket.accept();
try{
System.out.println("connnection accept:" + socket);
BufferedReader in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
PrintWriter out = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())), true);//使用带true参数的构造函数实现输出流的自动刷新
while (true) {
String str = in.readLine();
if (str.equals("END")) {//约定好的结束标志
break;
}
System.out.println("echoing:" + str);
out.println("加个标志" + str);//返回处理后的结果
}
}catch(IOException e){
e.printStackTrace();
}finally{
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}finally{
serversocket.close();
}
}
}

{code}

客户端代码

{code}

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;

public class JabberClient {

public static void main(String[] args) throws IOException {
InetAddress addr = InetAddress.getByName(null);
System.out.println("addr=" + addr);
Socket socket = new Socket(addr, 8080);
try {
System.out.println("socket=" + socket);
BufferedReader br = new BufferedReader(new InputStreamReader(socket
.getInputStream()));
PrintWriter pw = new PrintWriter(new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())), true);
for (int i = 0; i < 10; i++) {
pw.println("随便写点什么，再加个标志，linenum：" + i);
String str = br.readLine();
System.out.println("返回的结果：" + str);
}
pw.println("END");
} catch (IOException e) {
e.printStackTrace();
} finally {
socket.close();
}
}
}