黑马程序员_Java基础——网络编程（第7篇）

----------------------
ASP.Net+Unity开发、.Net培训、期待与您交流！ ----------------------

一、简介

    网络编程在如今的开发中是必不可少的，互联网时代有其独特的特点，没有网络寸步难行。粗糙点说，网络编程就是Socket编程。Socket就是为网络服务提供的一种机制。好比，Socket就是插座，是应用程序之间的逻辑插座(插口)，通信的两端都有Socket，网络通信其实就是Socket间的通信，数据在两个Socket之间通过IO流通信。

    网络通信的有其自己的要素，首先是要寻找到目标的机子，那么就需要IP地址来标注来源和去向。其次就是端口，端口为程序标识，有效的端口在0~65535之间，一般0~1024为系统所用或是保留端口。三就是最复杂的传输协议了，Socket是程序的通信端点，但是每个应用程序建立端点都有自己的方式，所以程序间所使用的协议是不一样的，使用最广泛的协议便是UDP和TCP协议。

二、UDP和TCP

    目前使用最广泛的就是UDP和TCP协议。两者各有优点各有缺点：

UDP：1.将数据的源和目的地封装成数据包中，不需要建立连接；

     2.每个数据包的大小控制在64K之内；

     3.因为是面向无连接的，所以UDP协议是不可靠协议；

     4.因为不需要建立连接，所以速度更快。

用处：聊天、视频会议、网游

TCP：1.建立连接，形成通道；

     2.在连接中进行大数据量的数据传输；

     3.通过三次握手完成连接，是可靠协议；

     4.必须建立连接，效率稍低。

用处：下载

三、示例

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

思路：建立udpsocket服务

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

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

      关闭资源

      有，有发送端就有接受端，否则，发出去的数据无人接受只能丢失

import java.net.*;
class Send//发送端
{
public static void main(String[] args)throws Exception
{
//创建udp服务，建立插座
DatagramSocket ds = new DatagramSocket();

//确定数据，并封装成数据包DatagramPacket(byte[] buf, int length, InetAddress address, int port)
String str = "asdadsasd";
DatagramPacket dp
= new DatagramPacket(str.getBytes(), str.length(), InetAddress.getLocalHost(), 10000);

//通过 Socket 服务将数据发送出去
ds.send(dp);

//关闭资源
ds.close();
}
}
class Receive//接收端
{
public static void main(String[] args)throws Exception
{
//创建udp服务，建立插座
DatagramSocket ds = new DatagramSocket(10000);
//创建一个数据包用来存放发送过来的数据包
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf, buf.length);
//从插座处接受发送来的数据包
ds.receive(dp);
String str = new String(dp.getData(), 0, dp.getLength());
System.out.println(str);
ds.close();
}
}//接收端要先存在才能收到数据，所以调试时要先打开receive接收端，再在另一个命令窗口打开Send端，否则数据只能丢失。

//使用Tcp协议，建立Tcp连接，客户端给服务端发送一段数据，收到后，服务端返回给客户端一段数据

import java.net.*;
import java.io.*;
class TcpClient
{
public static void main(String[] args)throws Exception
{
//建立套接字指定ip地址和端口号
Socket s = new Socket("127.0.0.1", 10004);
//得到网络写出流
OutputStream os = s.getOutputStream();
//往外写字符
os.write("sdhjsjdhjs去去去去".getBytes());
//os.close();

InputStream is = s.getInputStream();
byte[] buf = new byte[1024];
int len;
while((len = is.read(buf)) != -1)
{
System.out.println(new String(buf, 0, len));
}
os.close();
is.close();
}
}
class TcpServer
{
public static void main(String[] args)throws Exception
{
//监听服务器的指定端口
ServerSocket ss = new ServerSocket(10004);
//得到连接过来客户端对象
Socket s = ss.accept();
//得到读流
InputStream is = s.getInputStream();
byte[] buf = new byte[1024];
int len;
len = is.read(buf);

System.out.println(new String(buf, 0, len));
/*//为什么？循环就不行，结束不了
while((len = is.read(buf)) != -1)
{
System.out.println(new String(buf, 0, len));
}
*/
OutputStream os = s.getOutputStream();
//Thread.sleep(1000);
os.write("收到收到".getBytes());
is.close();
}
}//如上Udp示例，如果在一台机子上调试也需要两个命令窗口，一个做客户端，一个做服务端。

//需求：由客户端给服务端文本发送数据，服务端将其转换为大写返回给客户端

import java.io.*;
import java.net.*;
class TcpClient
{
public static void main(String[] args)throws Exception
{

Socket s = new Socket("127.0.0.1", 10005);
BufferedReader bufr2 = new BufferedReader(new InputStreamReader(s.getInputStream()));
BufferedWriter bufw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
//键盘录入
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line = bufr.readLine()) != null)
{
if("quit".equals(line))
break;
bufw.write(line);
bufw.newLine();//换行
bufw.flush();//刷新
String str = bufr2.readLine();
System.out.println(str);
}

s.close();
}
}
class TcpServer
{
public static void main(String[] args)throws Exception
{
ServerSocket ss = new ServerSocket(10005);
Socket s = ss.accept();
BufferedReader bufr = new BufferedReader(new InputStreamReader(s.getInputStream()));
BufferedWriter bufw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
String line = null;
while((line = bufr.readLine()) != null)
{
line = line.toUpperCase();
System.out.println(line);
bufw.write(line);
bufw.newLine();//换行
bufw.flush();//刷新
}
s.close();
ss.close();
}
}//这个程序中使用了字符流读取行数据，所以换行符的读入以及刷新的使用都非常重要，否则很可能出现莫名其妙的等待的情况！

----------------------
ASP.Net+Unity开发、.Net培训、期待与您交流！ ----------------------