java实现网络监听
2015-06-04 09:58
465 查看
Java实现网络监听
import java.net.*; import java.io.*; public class tcpServer { public static void main(String args[]) { int port; ServerSocket server_socket; BufferedReader input; try { port = Integer.parseInt(args[0]); } catch (Exception e) { System.out.println("port = 1500 (default)"); port = 1500; } try { server_socket = new ServerSocket(port); System.out.println("Server waiting for client on port " + server_socket.getLocalPort()); // server infinite loop while(true) { Socket socket = server_socket.accept(); System.out.println("New connection accepted " + socket.getInetAddress() + ":" + socket.getPort()); input = new BufferedReader(new InputStreamReader(socket.getInputStream())); // print received data try { while(true) { String message = input.readLine(); if (message==null) break; System.out.println(message); } } catch (IOException e) { System.out.println(e); } // connection closed by client try { socket.close(); System.out.println("Connection closed by client"); } catch (IOException e) { System.out.println(e); } } } catch (IOException e) { System.out.println(e); } } } import java.net.*; import java.io.*; public class tcpClient { public static void main(String[] args) { int port = 1500; String server = "localhost"; Socket socket = null; String lineToBeSent; BufferedReader input; PrintWriter output; int ERROR = 1; // read arguments if(args.length == 2) { server = args[0]; try { port = Integer.parseInt(args[1]); } catch (Exception e) { System.out.println("server port = 1000 (default)"); port = 1500; } } // connect to server try { socket = new Socket(server, port); System.out.println("Connected with server " + socket.getInetAddress() + ":" + socket.getPort()); } catch (UnknownHostException e) { System.out.println(e); System.exit(ERROR); } catch (IOException e) { System.out.println(e); System.exit(ERROR); } try { input = new BufferedReader(new InputStreamReader(System.in)); output = new PrintWriter(socket.getOutputStream(),true); // get user input and transmit it to server while(true) { lineToBeSent = input.readLine(); // stop if input line is "." if(lineToBeSent.equals(".")) break; output.println(lineToBeSent); } } catch (IOException e) { System.out.println(e); } try { socket.close(); } catch (IOException e) { System.out.println(e); } } }
相关文章推荐
- TCP与UDP在socket编程中的区别 (网络收集转载)
- java实现网络监听
- HTTP 304状态分析
- C#的百度地图开发(一)发起HTTP请求
- 关于 $http.get在项目打包后,手机端运行无法取得数据
- RMI、Hessian、Burlap、Httpinvoker、WebService的比较
- iOS应用架构谈 网络层设计方案
- libNids TCP 分析
- 自己动手写一个 iOS 网络请求库(四)——快速文件上传
- iOS应用架构谈 网络层设计方案
- js+html+css实现简单页面交互功能(2015知乎前端笔试题)http://v.youku.com/v_show/id_XMTI0ODQ5NTAyOA==.html?from=y1.7-1.2
- http及其请求方法(二)
- http及其请求方法(一)
- 眼睛不好者的福音,超大字版本万能五笔!
- 关于使用XMLHTTP的艰苦经历
- TCP学习(二)功能
- HTTP头部详解
- Android平台实现https信任所有证书的方法
- iOS 网络请求库(一)—— NSURLSession
- HttpClient学习整理