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

TCP Socket编程小结

2012-09-15 
TCP Socket编程总结TCP:是专门设计用于在不可靠的英特网上提供可靠的、端到端的字节流通信的协议,它是一个

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();}}

热点排行