TCP Socket编程总结
TCP:是专门设计用于在不可靠的英特网上提供可靠的、端到端的字节流通信的协议,它是一个面向连接的协议,TCP连接是字节流而非报文流。
package com.iflytek.socket;import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.Socket;/** * @author xudongwang 2012-1-9 * * Email:xdwangiflytek@gmail.com */public class EchoThread implements Runnable {private Socket client = null;public EchoThread(Socket client) {this.client = client;}@Overridepublic void run() {BufferedReader buf = null; // 接收输入流PrintStream out = null; // 打印流输出最方便try {out = new PrintStream(client.getOutputStream());// 准备接收客户端的输入信息buf = new BufferedReader(new InputStreamReader(client.getInputStream()));// 标志位,表示可以一直接收并回应信息boolean flag = true;while (flag) {// 接收客户端发送的内容String str = buf.readLine();if (str == null || "".equals(str)) { // 表示没有内容flag = false; // 退出循环} else {// 如果输入的内容为bye表示结束if ("bye".equals(str)) {flag = false;} else {out.println("ECHO : " + str); // 回应信息}}}client.close();} catch (Exception e) {}}}
?
?服务器端:
package com.iflytek.socket;import java.net.ServerSocket;import java.net.Socket;/** * @author xudongwang 2012-1-9 * * Email:xdwangiflytek@gmail.com */public class EchoThreadServer {public static void main(String args[]) throws Exception {ServerSocket server = null; // 定义ServerSocket类Socket client = null; // 表示客 户端server = new ServerSocket(8889); // 服务器在8888端口上监听boolean f = true; // 定义个标记位while (f) {System.out.println("服务器运行,等待客户端连接。");// 得到连接,程序进入到阻塞状态client = server.accept();// 每一个客户端表示一个线程new Thread(new EchoThread(client)).start();}server.close();}}?
?客户端:
package com.iflytek.socket;import java.io.BufferedReader;import java.io.InputStreamReader;import java.io.PrintStream;import java.net.Socket;/** * @author xudongwang 2012-1-9 * * Email:xdwangiflytek@gmail.com */public class EchoClient {public static void main(String args[]) throws Exception {Socket client = null; // 表示客 户端client = new Socket("localhost", 8889);BufferedReader buf = null; // 一次性接收完成PrintStream out = null; // 发送数据BufferedReader input = null; // 接收键盘数据input = new BufferedReader(new InputStreamReader(System.in));buf = new BufferedReader(new InputStreamReader(client.getInputStream()));out = new PrintStream(client.getOutputStream());boolean flag = true; // 定义标志位while (flag) {System.out.print("输入信息:");String str = input.readLine(); // 接收键盘的输入信息out.println(str);if ("bye".equals(str)) {flag = false;} else {String echo = buf.readLine(); // 接收返回结果System.out.println(echo); // 输出回应信息}}buf.close();client.close();}}