[关闭]
@liayun 2016-07-02T10:42:31.000000Z 字数 11570 阅读 1916

Java 网络编程(二)

java基础

两个案例

例1，需求：上传图片。
解：
定义客户端。
步骤：

  1. 建立服务端点。
  2. 读取客户端已有的图片数据。
  3. 通过Socket输出流将数据发给服务端。
  4. 读取服务端反馈信息。
  5. 关闭资源。
  1. class PicClient {
  2.     public static void main(String[] args) throws Exception {
  3.         Socket s = new Socket("10.48.16.235", 10007);
  4.         FileInputStream fis = new FileInputStream("c:/1.jpg");
  5.         OutputStream out = s.getOutputStream();
  6.         byte[] buf = new byte[1024];
  7.         int len = 0;
  8.         while((len=fis.read(buf)) != -1) {
  9.             out.write(buf, 0, len);
  10.         }
  12.         // 告诉服务端数据已写完
  13.         s.shutdownOutput();
  15.         InputStream in = s.getInputStream();
  16.         byte[] bufIn = new byte[1024];
  17.         int num = in.read(bufIn);
  18.         System.out.println(new String(buf, 0, num));
  19.         fis.close();
  20.         s.close();
  21.     }
  22. }

定义服务端。

  1. class PicServer {
  2.     public static void main(String[] args) throws Exception {
  3.         ServerSocket ss = new ServerSocket(10007);
  4.         Socket s = ss.accept();
  5.         InputStream in = s.getInputStream();
  6.         FileOutputStream fos = new FileOutputStream("server.jpg");
  7.         byte[] buf = new byte[1024];
  8.         int len = 0;
  9.         while((len=in.read(buf)) != -1) {
  10.             fos.write(buf, 0, len);
  11.         }
  12.         OutputStream out = s.getOutputStream();
  13.         out.write("上传成功!".getBytes());
  14.         fos.close();
  15.         s.close();
  16.         ss.close();
  17.     }
  18. }

这个服务端有个局限性，当A客户端连接上以后，被服务端获取到，服务端执行具体流程。这时B客户端连接，只有等待，因为服务端还没有处理完A客户端的请求，还没有循环回来执行下一次accpet()方法，所以暂时获取不到B客户端对象。
那么为了可以让多个客户端同时并发访问服务端，服务端最好就是将每个客户端封装到一个单独的线程中，这样就可以同时处理多个客户端请求。
那么如何定义线程呢？只要明确了每一个客户端在服务端执行的代码即可。将该代码存入run()方法中。代码如下：

  1. class PicThread implements Runnable {
  2.     private Socket s;
  3.     PicThread(Socket s) {
  4.         this.s = s;
  5.     }
  6.     public void run() {
  7.         int count = 1;
  8.         String ip = s.getInetAddress().getHostAddress();
  9.         try {
  11.             System.out.println(ip+".........connected");
  13.             InputStream in = s.getInputStream();
  15.             File file = new File(ip+"("+(count)+")"+".jpg"); // 10.48.16.235(1).jpg
  16.             while(file.exists()) {
  17.                 file = new File(ip+"("+(count++)+")"+".jpg");
  18.             }
  21.             FileOutputStream fos = new FileOutputStream(file);
  22.             byte[] buf = new byte[1024];
  23.             int len = 0;
  24.             while((len=in.read(buf)) != -1) {
  25.                 fos.write(buf, 0, len);
  26.             }
  27.             OutputStream out = s.getOutputStream();
  28.             out.write("上传成功!".getBytes());
  29.             fos.close();
  30.             s.close();
  31.         } catch (Exception e) {
  32.             throw new RuntimeException(ip+"上传失败！");
  33.         }
  34.     }
  35. }

那么服务端的代码为：

  1. class PicServer {
  2.     public static void main(String[] args) throws Exception {
  3.         ServerSocket ss = new ServerSocket(10007);
  4.         while(true) {
  5.             Socket s = ss.accept();
  6.             new Thread(new PicThread(s)).start();
  7.         }
  8.     }
  9. }

以上代码是怎么实现让多个客户端同时并发访问服务端的呢？一张图来理解：

为了让客户端的代码更加严谨，可对要上传的图片路径做一系列判断，如下：

  1. class PicClient {
  2.     public static void main(String[] args) throws Exception {
  4.         if(args.length != 1) {
  5.             System.out.println("请选择一个jpg格式的图片");
  6.             return;
  7.         }
  9.         File file = new File(args[0]);
  10.         if(!(file.exists() && file.isFile())) {
  11.              System.out.println("该文件有问题，要么不存在，要么不是文件");
  12.              return;
  13.         }
  14.         if(!file.getName().endsWith(".jpg")) {
  15.             System.out.println("图片格式错误，请重新选择");
  16.             return;
  17.         }
  18.         if(file.length() > 1024*1024*5) {
  19.             System.out.println("文件过大，没安好心");
  20.             return;
  21.         }
  24.         Socket s = new Socket("10.48.16.235", 10007);
  25.         FileInputStream fis = new FileInputStream(file);
  26.         OutputStream out = s.getOutputStream();
  27.         byte[] buf = new byte[1024];
  28.         int len = 0;
  29.         while((len=fis.read(buf)) != -1) {
  30.             out.write(buf, 0, len);
  31.         }
  33.         // 告诉服务端数据已写完
  34.         s.shutdownOutput();
  36.         InputStream in = s.getInputStream();
  37.         byte[] bufIn = new byte[1024];
  38.         int num = in.read(bufIn);
  39.         System.out.println(new String(buf, 0, num));
  40.         fis.close();
  41.         s.close();
  43.     }
  44. }

例2，客户端通过键盘录入用户名，服务端对这个用户名进行校验。如果该用户存在，在服务端显示XXX，已登录，并在客户端显示XXX，欢迎光临。如果该用户不存在，在服务端显示XXX，尝试登录，并在客户端显示XXX，该用户不存在。最多就登录3次。
服务端用户数据为：

  1. zhangsan
  2. lisi
  3. wangwu
  4. sunba
  5. zhouqi

解：

演示客户端和服务端

URL类

类URL代表一个统一资源定位符，它是指向互联网“资源”的指针。
此类必须掌握以下方法：

例，以下代码

  1. class URLDemo {
  2.     public static void main(String[] args) throws MalformedURLException {
  3.         URL url = new URL("http://10.48.16.235:8888/myWeb/demo.html?name=haha&age=30");
  5.         System.out.println("getProtocol():"+url.getProtocol());
  6.         System.out.println("getHost():"+url.getHost());
  7.         System.out.println("getPort():"+url.getPort());
  8.         System.out.println("getPath():"+url.getPath());
  9.         System.out.println("getFile():"+url.getFile());
  10.         System.out.println("getQuery():"+url.getQuery());
  12.         // 不写端口时，给一个默认的端口号80
  13.         /*
  14.         int port = url.getPort();
  15.         if(port == -1) 
  16.             port = 80;
  17.         */
  18.     }
  19. }

输出：

getProtocol():http
getHost():10.48.16.235
getPort():8888
getPath():/myWeb/demo.html
getFile():/myWeb/demo.html?name=haha&age=30
getQuery():name=haha&age=30

URLConnection抽象类

此抽象类代表应用程序和URL之间的通信链接。此类的实例可用于读取和写入此URL引用的资源。它封装了Socket。
示例代码如下：

  1. class URLConnectionDemo {
  2.     public static void main(String[] args) throws Exception {
  3.         URL url = new URL("http://192.168.1.116:8888/myWeb/demo.html");
  5.         URLConnection conn = url.openConnection();
  6.         System.out.println(conn); // 输出：sun.net.www.protocol.http.HttpURLConnection:http://192.168.1.116:8888/myWeb/demo.html
  8.         InputStream in = conn.getInputStream();
  9.         byte[] buf = new byte[1024];
  10.         int len = in.read(buf);
  11.         System.out.println(new String(buf, 0, len));
  12.     }
  13. }

所以自定义图形界面浏览器代码优化之后为：

  1. import java.awt.*;
  2. import java.awt.event.*;
  3. import java.io.*;
  4. import java.net.*;
  6. class MyIEByGUI2 {
  7.     private Frame f;
  8.     private TextField tf;
  9.     private Button but;
  10.     private TextArea ta;
  12.     private Dialog d;
  13.     private Label lab;
  14.     private Button okBut;
  16.     MyIEByGUI2() {
  17.         init();
  18.     }
  20.     public void init() {
  21.         f = new Frame("my window");
  22.         f.setBounds(300, 100, 600, 500);
  23.         f.setLayout(new FlowLayout());
  25.         tf = new TextField(60);
  27.         but = new Button("转到");
  29.         ta = new TextArea(25, 68);
  31.         /*
  32.         对话框也是一个窗体，最好不要加到Frame里面去
  33.         */
  34.         d = new Dialog(f, "提示信息-self", true); // true：对话框不处理掉，后面的窗体是无法操作的！！
  35.         d.setBounds(400, 200, 240, 150);
  36.         d.setLayout(new FlowLayout());
  37.         lab = new Label();
  38.         okBut = new Button("确定");
  40.         d.add(lab);
  41.         d.add(okBut);
  43.         f.add(tf);
  44.         f.add(but);
  45.         f.add(ta);
  47.         myEvent();
  48.         f.setVisible(true);
  49.     }
  51.     private void myEvent() {
  52.         // 点击对话框中的确定按钮，对话框也不显示出来
  53.         okBut.addActionListener(new ActionListener() {
  54.             public void actionPerformed(ActionEvent e) {
  55.                 d.setVisible(false);
  56.             }
  57.         });
  59.         // 关闭对话框，对话框不显示
  60.         d.addWindowListener(new WindowAdapter() {
  61.             public void windowClosing(WindowEvent e) {
  62.                 d.setVisible(false);
  63.             }
  64.         });
  66.         tf.addKeyListener(new KeyAdapter() {
  67.             public void keyPressed(KeyEvent e) {
  69.                 try {
  70.                     if(e.getKeyCode() == KeyEvent.VK_ENTER)
  71.                     showDir();
  72.                 } catch (Exception ex) {
  74.                 }
  76.             }
  77.         });
  79.         but.addActionListener(new ActionListener() {
  80.             public void actionPerformed(ActionEvent e) {
  82.                 try {
  83.                     showDir();
  84.                 } catch (Exception ex) {
  86.                 }
  88.             }
  89.         });
  91.         f.addWindowListener(new WindowAdapter() {
  92.             public void windowClosing(WindowEvent e) {
  93.                 System.exit(0);
  94.             }
  95.         });
  96.     }
  98.     private void showDir() throws Exception {
  99.         ta.setText("");
  100.         String urlPath = tf.getText(); // http://192.168.1.116:8888/myWeb/demo.html
  102.         URL url = new URL(urlPath);
  104.         URLConnection conn = url.openConnection();
  106.         InputStream in = conn.getInputStream();
  107.         byte[] buf = new byte[1024];
  108.         int len = in.read(buf);
  109.         ta.setText(new String(buf, 0, len));
  110.     }
  112.     public static void main(String[] args) {
  113.         new MyIEByGUI2();
  114.     }
  115. }

图示其中的原理：

域名解析

域名解析用一张图说明：

添加新批注
在作者公开此批注前，只有你和作者可见。
回复批注