JAVA基础学习网络编程<一>

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

/**
*端口：对应用程序进行数字标识，以方便对方发送数据到指定的应用程序上
*通信协议：TCP/IP
*IP：127.0.0.1:本地回环地址，192.168.1.255广播地址，局域网
*网络模型：
*应用层、表示层、会话层、传输层（TCP、UDP）、网络层、数据链路层、物理层
*描述IP的类：InetAddres
*方法：getLocalHost返回主机名和IP地址
*      getHostName返回主机名
*      getByName(ip)获取指定ip的主机名 *           
*端口：0到65535之间的数字*
*TCP
*建立连接，形成传输数据的通道；
*在连接中进行大数据量的传输；
*通过三次握手完成连接，是可靠的协议；
*必须建立连接，效率会稍低
*
*UDP
*将数据及源和目的封装成数据包，不需要建立连接；
*每个数据报的大小限制在64k内；
*因为面向无连接，是不可靠协议；
*不需要建立连接，速度快
*/
/**
* Socket网络编程最重要的部分
* 插座，应用软件通信机制，通信的前提
*传输协议不同，建立Socket也不一样
*UDP用的插座的建立：DatagramPacket:数据报包，既能发送又能接受,用来实现投递服务
*send、receive
*
* @author shantui
*
*/
/**
* 通过UDP发送一段文字
* 1.建立updsocket服务
* 2.提供数据，并封装到数据包中
* 3.通过soceket发送出去
* 4.关闭资源
*/

基于UDP传输的UDP发送端代码

DatagramPacket(byte[] buf, int offset, int length, InetAddressaddress, int port)

zh_cn

构造数据报包，用来将长度为 length 偏移量为 offset 的包发送到指定主机上的指定端口号。length 参数必须小于等于 buf.length。

package nettest;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

public class UdpSend
{
    public static void main(String[] args)throws Exception
    {
        /*
        DatagramSocket ds =new DatagramSocket(8888);
        byte[] buf="dfaljahello".getBytes();
        //构造数据报包，将长度为length的包发送到指定主机的指定端口上
        DatagramPacket dp =
                new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.254"),20010);
        ds.send(dp);
        */
        //采用键盘录入方式：读一句发一句
        DatagramSocket ds =new DatagramSocket(8888);
        //标准键盘录入代码
        String line=null;
        BufferedReader bufr=
                new BufferedReader(new InputStreamReader(System.in));
        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"),10011);
            ds.send(dp);
        }
        ds.close();


    }

}

接收端代码

package nettest;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

/**
 * 定义一个用于接受基于udp协议的数据并处理
 * 1.定义udpsocket服务,同时指定监听的端口，只收这个端口过来的数据
 * 2.定义一个数据包，因为要存储接受到的数据
 * 3.通过receive将收到的数据存入定义好的数据包中
 * 4.通过数据包对象特有功能，取出数据并打印
 * 5.关闭资源
 */
public class UdpRece
{
    public static void main(String[] args) throws Exception
    {
        DatagramSocket ds =new DatagramSocket(10011);
        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());
        int port=dp.getPort();
        System.out.println(ip+".."+data+".."+port);
        }
    }

}

编写一个聊天室的程序

package nettest;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

/**
 * 编写聊天程序
 * 有接受和发送数据的部分
 * 这两部分需要同时执行
 * 利用多线程技术
 * 一个线程控制收，一个线程控制发
 * 因为收发动作不一致，所以定义两个run方法
 * 还要封装到不同的类中
 */

public class ChatDemo
{

    public static void main(String[] args) throws Exception
    {
        DatagramSocket sendSocket =new DatagramSocket();
        DatagramSocket receSocket =new DatagramSocket(10013);
        new Thread(new Send(sendSocket)).start();
        new Thread(new Send(receSocket)).start();

    }

}
class Send implements Runnable
{
    private DatagramSocket ds;
    public Send(DatagramSocket ds)
    {
        this.ds=ds;
    }
    public void run()
    {
        try {
            String line=null;
            BufferedReader bufr=
                    new BufferedReader(new InputStreamReader(System.in));
            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.254"),10013);
                ds.send(dp);
            }
        } catch (Exception e) {
            throw new RuntimeException("发送失败");
        }
    }
}
class Rece implements Runnable
{
    private DatagramSocket ds;
    private 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());
            //int port=dp.getPort();
            System.out.println(ip+".."+data);
            }
        } catch (Exception e) {
            throw new RuntimeException("接收失败");
        }
    }
}

基于TCP协议，传输文字，分为：客户端和服务端

package nettest;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

/*
 * TCP分客户端和服务端
 * Socket构造的时候，一 建立就要找对应的服务端
 * 创建socket服务并指定要连接 的主机和端口
 *
 */
}
class Clinet
{
   public static void main(String[] args) throws Exception
    {
    //建立客户端socket服务，并指定要连接 的主机和端口
     *
    Socket s=new Socket("192.168.1.254",10003);

     OutputStream out = s.getOutputStream();
     out.write("fadjfdasjafasfjdsafd".getBytes());
     s.close();
     }

}
class Server
{
    public static void main(String[] args)throws Exception
    {
        //建立服务端socket服务，并监听一个端口
        ServerSocket ss=new ServerSocket(10003);
        //通过accept方法获取连接过来的客户端对象
        Socket s= ss.accept();
        //获取客户端发送过来的数据，那么要使用客户端对象的读取流来读取数据
        InputStream in=s.getInputStream();
        byte[] buf=new byte[1024];
        int len =in.read(buf);
        System.out.println(new String(buf,0,len));
    }
}