//前台书写

import java.io.OutputStream;import java.net.InetAddress;import java.net.Socket;import java.util.Scanner;public class MyClient {    public static void main(String[] args) throws Exception {        //前台        Socket client =new Socket(InetAddress.getByName("localhost"),50000);        OutputStream os = client.getOutputStream();        Scanner in =new Scanner(System.in);        String next = in.next();        os.write(next.getBytes());        os.close();    }}

//后台书写

import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class MyServer {    public static void main(String[] args) throws Exception {         //ServerSocket 可以      net           //01.在server创建一个用于   监听的 Socket            ServerSocket socket=new ServerSocket(50000);            System.out.println("Server开始监听了，呵呵！！！~~~~~");            //对方的数据过来，接收到   对方的数据过来的时候 以流的形态存在            //用于通信的Socket            while(true){                Socket accept=socket.accept();                MyMethread t1=new MyMethread();                t1.accept=accept;                t1.start();            }    }}

//Methread

import java.io.IOException;import java.io.InputStream;import java.net.Socket;public class MyMethread extends Thread {    public Socket accept =null;    @Override    public void run() {        try {            InputStream inputStream = accept.getInputStream();            byte [] bytes =new byte[1024];            int data;            if((data=inputStream.read(bytes,0,bytes.length))!=-1){                String temp =new String(bytes,0,data);                System.out.println(temp+"\t"+accept.getPort());            }        } catch (IOException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }    }}