Java学习---TCP Socket的学习

 1 import java.net.*;     
 2 import java.io.*;
 3 
 4 class myJava{
 5     public static void main(String [] args){
 6         String host = "222.24.16.";       
 7         String host_ip = null;
 8         Socket cs = null;
 9         for(int i=1; i<17; i++){             
10             host_ip = host + i;
11             for(int j=0; j<65536; j++){            
12                 try{
13                     cs = new Socket(host_ip, j);          
14                     System.out.println(host_ip + " : " + j);
15                 }catch(Exception e){                
16                     System.err.println();
17                 }
18             }
19         }
20     }
21 }

 1 //客户端
 2 import java.io.*;
 3 import java.net.*;
 4 public class MyClient{
 5     public static void main(String args[]) throws IOException{
 6         Socket comSocket = null;
 7         PrintStream out = null;
 8         DataInputStream in = null;
 9         try{
10             //建立socket连接
11             comSocket = new Socket("localhost", 1080);//相指定服务器的端口发出连接请求，注意服务器开放的TCP端口号
12             //分别对应服务器端的O/I流
13             in = new DataInputStream(comSocket.getInputStream());
14             out = new PrintStream(comSocket.getOutputStream());
15         }catch(UnknownHostException e){
16             System.err.println("Can‘t find the Server host");
17             System.exit(0);
18         }catch(IOException e){
19             System.err.println("Can‘t get I/O for the Connection");
20             System.exit(0);
21         }
22     
23         DataInputStream stdIn = new DataInputStream(System.in);
24         String fromServer, fromUser;
25     
26         while((fromServer = in.readLine()) != null){
27             System.out.println("Server:" + fromServer);
28             if(fromServer.equals("bye")) break;
29             fromUser = stdIn.readLine();
30             if(fromUser != null){
31                 System.out.println("Client:" + fromUser);
32                 out.println(fromUser);
33             }
34         }
35         out.close();
36         in.close();
37         stdIn.close();
38         comSocket.close();
39     }
40 }

 1 import java.io.*;
 2 import java.net.*;
 3 
 4 public class ScanPort{
 5     public static void main(String args[]) throws IOException{
 6         Socket comSocket = null;
 7         
 8         for(int i=0;i<1024; i++){
 9             try{
10                 //建立socket连接
11                 comSocket = new Socket("localhost", i);//发出连接请求
12                 
13                 System.out.println("Can get I/O for the Connection, Port:" + i);
14             }catch(UnknownHostException e){
15                 System.err.println("Can‘t find the Server host");
16                 //System.exit(0);
17             }catch(IOException e){
18                 System.err.println("Can‘t get I/O for the Connection, Port:" + i);
19                 //System.exit(0);
20             }
21         }
22         
23         try{
24             comSocket.close();
25         }catch(Exception e){}
26     }
27 }

 1 //采用TCP进行通讯，需要服务器和客户端两个部分，因此程序包含SendFileServer.java和SendFileClient.java两个部分。两个文件的IP，端口都在程序中指定, 传输的文件路径也在程序中指定
 2 ////////////SendFileServer.java
 3 import java.io.FileInputStream;
 4 import java.io.IOException;
 5 import java.io.OutputStream;
 6 import java.net.ServerSocket;
 7 import java.net.Socket;
 8 /*
 9  * 用TCP进行文件传输
10  * 此文件为服务器文件
11  * 当接受到客户端的请求之后，先向其传输文件名
12  * 当客户端接受完毕之后，向客户端传输文件
13  * */
14 public class SendFileServer implements Runnable{
15     // 服务器监听端口
16     private static final int MONITORPORT  = 12345;
17     private Socket s ;
18     public SendFileServer(Socket s) {
19         super();
20         this.s = s;
21     }
22     public static void server()
23     {
24         try {
25             // 创建服务器socket
26             ServerSocket ss = new ServerSocket(MONITORPORT);
27             while(true)
28             {
29                 // 接收到一个客户端连接之后，创建一个新的线程进行服务
30                 // 并将联通的socket传给该线程
31                 Socket s = ss.accept();
32                 new Thread(new SendFileServer(s)).start();
33             }
34         } catch (IOException e) {
35             // TODO Auto-generated catch block
36             e.printStackTrace();
37         }
38     }
39     /**
40      * @param args
41      */
42     public static void main(String[] args) {
43         // TODO Auto-generated method stub
44         SendFileServer.server();
45     }
46     @Override
47     public void run() {
48         // TODO Auto-generated method stub
49         byte[] buf = new byte[100];
50         OutputStream os=null;
51         FileInputStream fins=null;
52         try {
53             os = s.getOutputStream();
54             // 文件路径
55             String filePath = "/home/newton/cangjie.mp3";
56             // 文件名
57             String fileName = "cangjie.mp3";
58             System.out.println("将文件名:"+fileName+"传输过去");
59             //先将文件名传输过去
60             os.write(fileName.getBytes());
61             System.out.println("开始传输文件");
62             //将文件传输过去 
63             // 获取文件
64             fins = new FileInputStream(filePath);
65             int data;
66             // 通过fins读取文件，并通过os将文件传输
67             while(-1!=(data = fins.read()))
68             {
69                 os.write(data);
70             }
71             System.out.println("文件传输结束");
72         } catch (IOException e) {
73             // TODO Auto-generated catch block
74             e.printStackTrace();
75         }finally
76         {
77             try {
78                 if(fins!=null) fins.close();
79                 if(os!=null)    os.close();
80                 this.s.close();
81             } catch (IOException e) {
82                 e.printStackTrace();
83             }
84         }
85     }
86 }

 1 import java.io.FileOutputStream;
 2 import java.io.IOException;
 3 import java.io.InputStream;
 4 import java.net.InetSocketAddress;
 5 import java.net.Socket;
 6 /*
 7  * 用TCP进行文件传输
 8  * 此文件为客户端文件
 9  * 连接上服务器之后，直接接受文件
10  * 
11  * */
12 public class SendFileClient {
13     private static final String SERVERIP = "127.0.0.1";
14     private static final int SERVERPORT = 12345;
15     private static final int CLIENTPORT = 54321;
16     /**
17      * @param args
18      */
19     public static void main(String[] args) {
20         // TODO Auto-generated method stub
21         // 用来接受传输过来的字符
22         byte[] buf = new byte[100];
23         Socket s = new Socket();
24         try {
25             // 建立连接
26             s.connect(new InetSocketAddress(SERVERIP,SERVERPORT), CLIENTPORT);
27             InputStream is = s.getInputStream();
28             // 接收传输来的文件名
29             int len = is.read(buf);
30             String fileName = new String(buf,0,len);
31             System.out.println(fileName);
32             //接收传输来的文件
33             FileOutputStream fos = new FileOutputStream(fileName);
34             int data;
35             while(-1!=(data = is.read()))
36             {
37                 fos.write(data);
38             }
39             is.close();
40             s.close();
41         } catch (IOException e) {
42             // TODO Auto-generated catch block
43             e.printStackTrace();
44         }
45     }
46 }