JAVASE入门十四脚-线程池,ip,端口,通信协议,socket,seversocket

package com.ma;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TheadPoolDemo {
    public static void main(String[] args) {
        ThreadPoolExecutor threadPoolExecutor=new ThreadPoolExecutor(1,1,60, TimeUnit.SECONDS,new ArrayBlockingQueue(5));
        threadPoolExecutor.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println(Math.random());
            }
        });
        threadPoolExecutor.shutdown();
    }
}

 socket

package SeverDemoPlus;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class SeverDemoP {
    public static void main(String[] args) throws IOException {
        ServerSocket sever=new ServerSocket(10086);
        Socket socket=sever.accept();
        InputStream inputStream=socket.getInputStream();
        DataInputStream dataInputStream=new DataInputStream(inputStream);
        System.out.println(dataInputStream.readUTF());
        dataInputStream.close();
        socket.close();
        sever.close();
    }
}

package Cilcent;

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

public class Client {
    public static void main(String[] args) throws IOException {
        Socket socket=new Socket("127.0.0.1",10086);
        OutputStream outputStream=socket.getOutputStream();
        DataOutputStream dataOutputStream=new DataOutputStream(outputStream);
        dataOutputStream.writeUTF("你好,我是客户端");
        dataOutputStream.close();
        outputStream.close();
        socket.close();


    }
}

socket与seversocket

package Cilcent;

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

public class Client2 {
    public static void main(String[] args) throws IOException {
        Socket socket=new Socket("localhost",10001);
        OutputStream outputStream=socket.getOutputStream();
        outputStream.write("hahaha".getBytes());
        InputStream inputStream=socket.getInputStream();
        byte[] bytes=new byte[1024];
        int length=inputStream.read(bytes);
        System.out.println("服务端传入的数据是"+new String(bytes,0,length));
        inputStream.close();
        outputStream.close();
        socket.close();



    }
}

package SeverDemoPlus;

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

public class SeverDemoppp {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket=new ServerSocket(10001);
        Socket socket=serverSocket.accept();
        InputStream inputStream=socket.getInputStream();
        byte[] bytes=new byte[1024];
        int length=inputStream.read(bytes);
        System.out.println("客服端输入数据是"+new java.lang.String(bytes,0,length));

        OutputStream outputStream=socket.getOutputStream();
        outputStream.write("你好,我是服务端".getBytes());
        outputStream.close();
        inputStream.close();
        socket.close();
        serverSocket.close();
    }
}