黑马程序员——java学习之网络编程

            ------Java培训、Android培训、iOS培训、.Net培训、期待与您交流！ -------

       之前学习网络编程，感觉这部分很难，着实是没有掌握，重新学习了之后发现只要明确了流程，也就是Socket类的过程，通过一般的需求分析，按照流程并不难掌握。初次之外有些注意点记得不要遗漏。网络编程部分的学习主要还是以掌握TCP，UDP为主，辅以多加练习。

      

一，基础

1，数据通讯的原理就是数据传输。
2，基本3要素：
              2.1：找到对方ip
              ##IP--本地主机：localhost     类：InetAddress。无构造函数。
              ##过程：InetAddress i = InetAddress.getLocalHost--静态
              ##方法：getHostAddress（），getHostName（）
              ##另外：如果IP有很多，可以变成数组，少用。
              注意：如果IP地址与对应主机没有映射关系，解析不出来。
              **面向对象将复杂事物简单化。
              2.2：数据要发送到对方指定的程序，网络应用程序有自己的数字标示。这就是逻辑端口。
              2.3：定义通讯规则，称为协议。TCP/IP协议。      
3，网络模型：
              3.1：OSI参考模型--7层
              3.2：TCP/IP--应用层，传输层，网际层，主机至网络层
              ##传输层：TCP/UDP      网际层：IP   
4：重点：
              4.1：UDP
              ##封包，不需要建立链接。会丢包。速度快。--桌面共享，聊天都是UDP传输。
              4.2：TCP
              ##面向链接的。数据量大。下载用TCP。
              java提供对象。

二：Socket：

基本：网络编程就是Socket编程。
概念：为网络服务提供一种机制。数据两端都有Socket。数据在两个Socket上进行IO传输。

1，UDP

     1.1：对象：DategramSocket
   1.2：send（）发送。抛异常。
        过程：1：建立udpsocket服务。
                 DategramSocket ds = new DategramSocket();
              2：提供数据，并封装到数据包
                 Byte[] buf ="udp".getBytes（）；
                 DategramPacket dp = new 
                 DategramPacket（buf，buf.lengh,InetAddress.getByName(ip),端口）；
              3：发送。
                 ds.send(dp);
              4：关闭资源。
                 ds.close();
    1.3：receive
              过程：1：同上。
                    2：定义一个数据包，用于存储接收到的字节数组。
                       Byte[] buf =new Byte[1024]；
                       DategramPackage dp = new DategramPackage（buf,buf.length）
                    3：receive方法存储数据到数据包中
                       ds.receive(dp);
                    4：将不同的数据取出。
                       getAddress（），getPort（），
                    5：关闭资源 
                       ---还要定义UDP的接收端时还要指定端口。
                    DategramSocket ds = new DategramSocket(端口)；
    ##注意：注意流程。
练习，键盘录入通讯:

import java.net.*;
import java.io.*;
class  UdpSend2
{
public static void main(String[] args) throws Exception
{
DatagramSocket ds = new DatagramSocket();
BufferedReader bufr =
new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line=bufr.readLine())!=null)
{
if("886".equals(line))
break;
byte[] buf = line.getBytes();
DatagramPacket dp =
new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10001);

ds.send(dp);
}
ds.close();
}
}
class  UdpRece2
{
public static void main(String[] args) throws Exception
{
DatagramSocket ds = new DatagramSocket(10001);
while(true)
{
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());
System.out.println(ip+"::"+data);
}
}
}

练习：聊天

import java.io.*;
import java.net.*;
class Send implements Runnable
{
private DatagramSocket ds;
public Send(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line=bufr.readLine())!=null)
{
byte[] buf = line.getBytes();
DatagramPacket dp =
new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10002);
ds.send(dp);
if("886".equals(line))
break;
}
}
catch (Exception e)
{
throw new RuntimeException("发送端失败");
}
}
}
class Rece implements Runnable
{
private DatagramSocket ds;
public Rece(DatagramSocket ds)
{
this.ds = ds;
}
public void run()
{
try
{
while(true)
{
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
ds.receive(dp);
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());
if("886".equals(data))
{
System.out.println(ip+"....离开聊天室");
break;
}
System.out.println(ip+":"+data);
}
}
catch (Exception e)
{
throw new RuntimeException("接收端失败");
}
}
}
class  ChatDemo
{
public static void main(String[] args) throws Exception
{
DatagramSocket sendSocket = new DatagramSocket();
DatagramSocket receSocket = new DatagramSocket(10002);
new Thread(new Send(sendSocket)).start();
new Thread(new Rece(receSocket)).start();
}
}

2，TCP

     
2.1：对象：socket和ServerSocket客户端和服务端
   2.2：客户端步骤：1：创建Socket服务，并指定连接的主机和客户端。
                       Socket s =new Socket(“主机”，端口号)； 
                    2：获取Socket中的输入流
                       OutputStream out =s.getOutputStream();
                       out.write("tcp".getBytes());因为是字节
                       s.close();
   2.3：服务端：1：建立ServerSocket服务端，并绑定端口。
                   ServerSocket ss =new ServerSocket（端口号）；
                2：获取连接对象--accept方法。
                   Socket s = ss.accept();
                3：服务端将客户端对象读取流的读取，并接收数据。
                   InputStream in =s.getInputStream();
                   Byte [] b =new byte[1024]；
                   int len =in.read(b); 
                                     
                4：关闭服务端。（可选操作）                        
练习：文本转换服务器

import java.io.*;
import java.net.*;
class  TransClient
{
public static void main(String[] args) throws Exception
{
Socket s = new Socket("192.168.1.254",10005);
BufferedReader bufr =
new BufferedReader(new InputStreamReader(System.in));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
BufferedReader bufIn =
new BufferedReader(new InputStreamReader(s.getInputStream()));
String line = null;
while((line=bufr.readLine())!=null)
{
if("over".equals(line))
break;
out.println(line);
String str =bufIn.readLine();
System.out.println("server:"+str);
}
bufr.close();
s.close();
}
}
class  TransServer
{
public static void main(String[] args) throws Exception
{
ServerSocket ss = new ServerSocket(10005);
Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip+"....connected");
BufferedReader bufIn =
new BufferedReader(new InputStreamReader(s.getInputStream()));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
String line = null;
while((line=bufIn.readLine())!=null)
{
System.out.println(line);
out.println(line.toUpperCase());
}
s.close();
ss.close();
}
}

        另外：PrintWriter自动刷新，可以传输任意流。
练习： 复制文件

import java.io.*;
import java.net.*;
class  TextClient
{
public static void main(String[] args) throws Exception
{
Socket s = new Socket("192.168.1.254",10006);
BufferedReader bufr =
new BufferedReader(new FileReader("test.java"));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
String line = null;
while((line=bufr.readLine())!=null)
{
out.println(line);
}
s.shutdownOutput();
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
String str = bufIn.readLine();
System.out.println(str);
bufr.close();
s.close();
}
}
class  TextServer
{
public static void main(String[] args) throws Exception
{
ServerSocket ss = new ServerSocket(10006);
Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip+"....connected");
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
PrintWriter out  = new PrintWriter(new FileWriter("server.txt"),true);
String line = null;
while((line=bufIn.readLine())!=null)
{
out.println(line);
}
PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
pw.println("上传成功");
out.close();
s.close();
ss.close();
}
}

       
shutdownOutput（），结束标记。关闭流，在流里加入结束标记。
        ##客户端并发访问服务端：服务端需要将每个客户端封装进一个单独的线程，
                                将该客户端代码存入到run方法中。
        telnet：windows中远程登陆的工具。

3，URl类

       
3.1：概念：URI比URL范围大
     3.2：方法：获取  getFile   getHost（）获取主机，getPort（），getPath（），
                     getProtocol（） getQuery（）能获取信息。
        ##必须掌握：URlConnection 
                   ---本身封装了一个URl地址，openConnection（）；
                  可以直接获取主机的链接对象。
                   ---抽象的，方法：getInputStream（），getOutputStream（），
                  不用关闭连接。
        另外：ServerSocket中有个backlog，表示链接服务端的最大客户端数。
        其他重点：域名解析。先找本地域名解析地址，本地可以提高速度。
                  DNS服务器：