网络编程

Posted 2021-10-27 findlisa

网络通信协议

static InetAddress getByName()	给定主机名确定IP
static InetAddress getLocalhost()	返回本地主机地址和主机名
String getHostName()	返回主机名
String  getHostAddress()	返回主机IP

InetAddress Inet=InetAddress.getLocalHost();
InetAddress Inet1=InetAddress.getByName("www.baidu.com");
System.out.println(Inet);
System.out.println(Inet1);
System.out.println(Inet.getHostName());
System.out.println(Inet.getHostAddress());

运行结果：

 

---

UDP

服务端：

InetAddress inet=InetAddress.getByName("127.0.0.1");
byte []buf="你好，世界！".getBytes();
//整个数组全发送出去
DatagramPacket dp=new DatagramPacket(buf,buf.length,inet,6000);
DatagramSocket ds=new DatagramSocket();
ds.send(dp);
ds.close();

客户端：

byte [] buf=new byte[1024];
DatagramPacket dp=new DatagramPacket(buf,buf.length);
//套接字绑定端口号
DatagramSocket ds=new DatagramSocket(6000);
ds.receive(dp);
//获取报文长度，避免打印空白字符
int length=dp.getLength();
//获取客户端端口口号
InetAddress ip=dp.getAddress().getHostAddress();
int port=dp.getPort();
System.out.println(ip+":"+port);
System.out.println(new String(buf,0,length));
ds.close();

注：客户端每次获取的端口好都有不一样，而且不是6000，原因是系统随机分配一个端口去和监听的6000端口对接。

可改造成while循环进行持续的发送接收。

---

 

TCP

客户端：

Socket socket=new Socket("127.0.0.1",1234);
//向服务器发送数据
OutputStream out=socket.getOutputStream();
out.write("世界你好".getBytes());
//接收服务器的数据
InputStream in=socket.getInputStream();
byte[] buf=new byte[1024];
in.read(buf);
System.out.println(new String(buf,0,buf.length));
        
socket.close();

服务端：

ServerSocket ss=new ServerSocket(1234);
//获取客户端的对象
Socket s=ss.accept();
//接收数据
InputStream in=s.getInputStream();
byte[] buf=new byte[1024];
in.read(buf);
System.out.println(new String(buf,0,buf.length));
//向客户端发送数据
OutputStream out=s.getOutputStream();
out.write("收到了，谢谢".getBytes());
        
s.close();
ss.close();

注：连接一旦建立，系统就会自动创建一个IO流对象，这时候要用socket对象去get这个流对象来进行读写。

        服务端没有socket对象，会通过serversocket对象accept()获取到客户端对象，也是这样来对客户端进行区分。 

　　 outputstream和inputsteam 的区分，把端当成一条steam即可，发送理解为拿数据出来-->out,接收理解为把数据放进去-->in。

 

---

TCP上传图片

 客户端：

Socket s=new Socket("127.0.0.1",2222);
OutputStream out=s.getOutputStream();
//将文件以字节读入入流中        
FileInputStream fis=new FileInputStream("c:\\\\k.jpg");
byte[]buf=new byte[1024];
//len用来记录有效长度
int len;
while((len=fis.read(buf))!=-1){
    out.write(buf,0,len);
        }
s.shutdownOutput();
        
//获取服务端返回的数据
InputStream in=s.getInputStream();
len=in.read(buf);
System.out.println(new String(buf,0,len));
        
s.close();

服务端：

ServerSocket ss=new ServerSocket(2222);
Socket s=ss.accept();
        
InputStream in=s.getInputStream();
byte [] buf=new byte[1024];
        
File filename=new File("d:\\\\upload");
//如果没有文件夹就会创建
if(!filename.exists()){filename.mkdirs();}
String str="wei"+System.currentTimeMillis()+newRandom().nextInt(999999)+".jpg";
FileOutputStream fos=new FileOutputStream(filename+"\\\\"+str);
        
int len=0;
while((len=in.read(buf))!=-1){
    fos.write(buf,0,len);
        }
//反馈结果给客户端
s.getOutputStream().write("上传成功".getBytes());
        
fos.close();
s.close();
ss.close();

变量len的意义在于记录数组改变的有效长度，读写的时候读写有效长度，防止读写原数组保留内容。

---

 

TCP实现多线程上传图片

public class upload implements Runnable{
    //将获得的socket传入
    private Socket s;
    public upload(Socket s){this.s=s;}
    
    @Override
    public void run() {
        try{
            
            InputStream in=s.getInputStream();
            byte [] buf=new byte[1024];
            
            File filename=new File("d:\\\\upload");
            //如果没有文件夹就会创建
            if(!filename.exists()){filename.mkdirs();}
            String str="wei"+System.currentTimeMillis()+new Random().nextInt(999999)+".jpg";
            FileOutputStream fos=new FileOutputStream(filename+"\\\\"+str);
            
            int len=0;
            while((len=in.read(buf))!=-1){
                fos.write(buf,0,len);
            }
            //反馈结果给客户端
            s.getOutputStream().write("上传成功".getBytes());
            
            fos.close();
            s.close();
        }catch(IOException e){
            System.out.println(e);
            throw new RuntimeException("上传错误！");
        }
    }

}

public class UploadServer {

    public static void main(String[] args) throws IOException{
        ServerSocket ss=new ServerSocket(2222);
        while(true){
            Socket s=ss.accept();        
            new Thread(new upload(s)).start();
        }
        
    }

}

注：客户端无需修改，当服务端接收到客户端发送的socket的对象时，开启线程，执行重写的run方法。