javase套接字编程

1、沟通多线程

package com.socket;

import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;

public class Communication extends Thread{
    private Socket socket;
    private String clientInfo;

    public Communication(Socket socket) {
        super();
        this.socket = socket;
        clientInfo=getClientInfo();
    }
    public void run(){
        //System.out.println("有连接了");
        InputStream is;
        try {
            is = socket.getInputStream();//获取输入流，读取客户端内容
            OutputStream os = socket.getOutputStream();//获取输出，回传给客户
            InputStreamReader isr = new InputStreamReader(is);
            char[] buf=new char[1024];
            int len=0;
            while((len=isr.read(buf))!=-1){
                String msg=new String(buf,0,len);
                
                System.out.println("["+clientInfo+"]"+msg);
                os.write(("[from chaofei]"+msg).getBytes());
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    //获取远程客户端信息
    private String getClientInfo(){
        try {
            InetSocketAddress addr = (InetSocketAddress) socket.getRemoteSocketAddress();
            String ip = addr.getAddress().getHostAddress();
            int port = addr.getPort();
            return ip+":"+port;
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
        
    }
}

2、服务器端

package com.socket;

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

import org.junit.Test;

/**
 * 只接受客户端内容，不进行回复
 * 
 * @author feigu
 *
 */
public class MySever {
    @Test
    public void start() {
        try {
            ServerSocket ss = new ServerSocket(8888);
            while (true) {

                Socket socket = ss.accept();// 接收客户端请求
                new Communication(socket).start();
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

3、客户端

package com.socket;

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

import org.junit.Test;

public class MyClient {
    @Test
    public void send() {
        try {
            Socket s = new Socket("localhost", 8888);
            OutputStream os = s.getOutputStream();
            InputStream is = s.getInputStream();
            BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
            String line = null;
            byte[] buf = new byte[1024];
            int len = 0;
            while ((line = br.readLine()) != null) {
                os.write(line.getBytes());
                len = is.read(buf);
                System.out.println(new String(buf, 0, len));
            }

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}