黑马程序员8--网络编程

网络编程

------- android培训、java培训、期待与您交流！ ----------

网络参考模型



IP地址:InetAddress
网络中设备的标识
不易记忆，可用主机名
本地回环地址：127.0.0.1 主机名：localhost

端口号
用于标识进程的逻辑地址，不同进程的标识
有效端口：0~65535，其中0~1024系统使用或保留端口。

传输协议
通讯的规则
常见协议：TCP，UDP

UDP
将数据及源和目的封装成数据包中，不需要建立连接
每个数据报的大小在限制在64k内
因无连接，是不可靠协议
不需要建立连接，速度快

TCP
建立连接，形成传输数据的通道。
在连接中进行大数据量传输
通过三次握手完成连接，是可靠协议
必须建立连接，效率会稍低

Socket就是为网络服务提供的一种机制。
通信的两端都有Socket。
网络通信其实就是Socket间的通信。
数据在两个Socket间通过IO传输。

UDP

/*

需求：通过udp传输方式，将一段文字数据发送出去。

定义了一个udp发送端

思路：

1.建立udpsocket服务。

2.提供数据，并将数据封装到数据包中。

3.通过socket服务的发送功能，将数据包发出去

4.关闭资源

*/

class UdpSend

{

public static void main(String[] args) throws Exception

{

//1 创建udp服务，通过DatagramSocket对象

DatagramSocket ds = new DatagramSocket(8888);

//2 确定数据，并封装成数据包。DatagramPacket(byte[] buf,int length,InetAddress address,int port)

byte[] buf = "udp ge men lai le".getBytes();

DatagramPacket dp = newDatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.111"),10000);

//3 通过socket服务，将已有的数据包发送出去。通过send方法

ds.send(dp);

//4 关闭资源

ds.close();

}

}

/*

需求：

定义一个应用程序，用于接收udp协议传输的数据并处理的。

定义udp的接收端。

思路：

1. 定义udpsocket服务。通常会监听一个端口。其实就是给这个接收网络应用程序定义数字标识。

方便于明确哪些数据过来该应用程序可以处理。

2.定义一个数据包，因为要存储接收到的字节数据。

因为数据包对象中有更多功能可以提取字节数据中的不同数据信息。

3.通过socket服务的receive方法将收到的数据存入已定义好的数据包中。

4.通过数据包对象的特有功能。将这些不同的数据取出。打印在控制台上

5.关闭资源。

*/

class UdpRece

{

public static void main(String[] args) throws Exception

{

//1 创建udp socket，建立端点

DatagramSocket ds = new DatagramSocket(10000);

//2 定义数据包，用于存储数据

byte[] buf = new byte[1024];

DatagramPacket dp = new DatagramPacket(buf,buf.length);

//3 通过服务的receive方法将收到数据存入数据包中

ds.receive(dp);

//4 通过数据包的方法获取其中的数据

String ip = dp.getAddress().getHostAddress();

String data = new String(dp.getData(),0,dp.getLength());

int port = dp.getPort();

System.out.println("ip:"+ip+" data:"+data+"
port:"+port);

System.out.println(new String( buf));

ds.close();

}

}

TCP

/*

演示tcp传输

1.tcp分客户端和服务端

2.客户端对应的对象是Socket

服务端对应的对象是ServerSocket

*/

/*

客户端，

通过查阅socket对象，发现在该对象建立时，就可以去连接指定主机。

因为tcp是面向连接的。所以在建立socket服务时。

就要有服务端存在，并连接成功。形成通路后，在该通道进行数据的传输。

步骤：

1.创建Socket服务。并指定要连接的主机和端口

*/

class TcpClient

{

public static void main(String[] args) throws Exception

{

//创建客户端的socket服务。指定目的主机和端口

Socket s = new Socket("192.168.1.111",10003);

//为了发送数据，应该获取socket流中的输出流

OutputStream out = s.getOutputStream();

out.write("I am coming.".getBytes());

s.close();

}

}

/*

需求：定义端点接收数据并打印在控制台上

服务器：

1.建立服务端的socket服务。ServerSocket

2.获取连接过来的客户端对象

通过ServerSocket的accept方法。没有连接就会等，所以这个方法阻塞式的

3.客户端如果发过来数据，那么服务端要使用对应的客户端对象，并获取到该客户端对象的读取流来读取发过来的数据。并打印在控制台。

4.关闭服务端。（可选）

*/

class TcpServer

{

public static void main(String[] args) throws Exception

{

//建立服务端socket服务，并监听一个端口

ServerSocket ss=new ServerSocket(10003);

//通过accept方法获取连接过来的客户端对象

Socket s = ss.accept();

String ip=s.getInetAddress().getHostAddress();

System.out.println(ip+".........connected");

//获取客户端发送过来的数据，那么要使用客户端对象的读取流来读取数据

InputStream in=s.getInputStream();

byte[] buf = new byte[1024];

int len=in.read(buf);

System.out.println(new String(buf,0,len));

s.close();//关闭客户端

ss.close();

}

}

客户端并发登陆

/*

客户端通过键盘录入用户名。

服务端对这个用户名进行校验

如果该用户存在，在服务端显示xxx，已登录

并在客户端显示 xxx，欢迎光临

如果该用户存在，在服务端显示xxx，尝试登录

并在客户端显示 xxx，该用户不存在。

最多就登录三次

*/

class LoginClient

{

public static void main(String[] args) throws Exception

{

Socket s = new Socket("192.168.1.111",10009);

BufferedReader bufr =

new BufferedReader(new InputStreamReader(System.in));

PrintWriter out = new PrintWriter(s.getOutputStream(),true);

BufferedReader bufIn =

new BufferedReader(new InputStreamReader(s.getInputStream()));

for (int i=0;i<3 ;i++ )

{

String line =bufr.readLine();

if (line==null)

{

break;

}

out.println(line);

String info=bufIn.readLine();

if (info.contains("欢迎"))

{

break;

}

System.out.println("info:"+info);

}

bufr.close();

s.close();

}

}

class UserThread implements Runnable

{

private Socket s;

UserThread(Socket s)

{

this.s=s;

}

public void run() throws Exception

{

String ip = s.getInetAddress().getHostAddress();

System.out.println(ip+".....connected");

for (int i=0;i<3 ;i++ )

{

BufferedReader bufIn =

new BufferedReader(new InputStreamReader(s.getInputStream()));

String name =bufIn.readLine();

if (name==null)

{

break;

}

BufferedReader bufr =

new BufferedReader(new FileReader("user.txt"));

PrintWriter out = new PrintWriter(s.getOutputStream(),true);

String line=null;

boolean flag=false;

while ((line=bufr.readLine())!=null)

{

if(line.equals(name))

{

flag=true;

break;

}

}

if (flag)

{

System.out.println(name+"已登录");

out.println(name+"欢迎光临");

}

else

{

System.out.println(name+"尝试登录");

out.println(name+"登陆失败");

}

}

s.close();

}

}

class LoginServer

{

public static void main(String[] args) throws Exception

{

ServerSocket ss = new ServerSocket(10009);

while (true)

{

Socket s=ss.accept();

new Thread(new UserThread(s)).start();

}

}

}

URL类

String getFile() //获取此 URL 的文件名。
String getHost() // 获取此 URL 的主机名（如果适用）。
String getPath() // 获取此 URL 的路径部分。
int getPort() // 获取此 URL 的端口号。
String getProtocol() // 获取此 URL 的协议名称。
String getQuery() // 获取此 URL 的查询部分。

class URLDemo

{

public static void main(String[] args) throws Exception

{

URL url = new URL("http://192.168.1.111:11100/myweb/main.html?name=leon");

System.out.println("getProtocol:"+url.getProtocol());

System.out.println("getHost:"+url.getHost());

System.out.println("getPort:"+url.getPort());

System.out.println("getPath:"+url.getPath());

System.out.println("getFile:"+url.getFile());

System.out.println("getQuery:"+url.getQuery());

}

}

class URLConnectionDemo

{

public static void main(String[] args) throws Exception

{

URL url = new URL("http://www.baidu.com");//此处可以链接，也可以是ip地址

URLConnection conn=url.openConnection();

System.out.println(conn);

InputStream in= conn.getInputStream();

byte[] buf = new byte[1024];

int len=0;

while ((len=in.read(buf))!=-1)

{

System.out.println(new String(buf,0,len));

}

}

}