java是一种可以撰写跨平台应用软件的面向对象的程序设计语言,是由Sun Microsystems公司于1995年5月推出的Java程序设计语言和Java平台(即JavaEE, JavaME, JavaSE)的总称。本站提供基于Java框架struts,spring,hibernate等的桌面应用、web交互及移动终端的开发技巧与资料

保持永久学习的心态,将成就一个优秀的你,来 继续搞起java知识。

多线程部分:

/**
 * Created by LiuHuiChao on 2016/3/11.
 * 服务器端线程处理类
 */
public class ServerThread extends Thread{
    //和本线程相关的socket
    <a href="http://www.cfei.net/archives/tag/socket" title="浏览关于“Socket”的文章" target="_blank" class="tag_link">Socket</a> socket=null;
    public ServerThread(Socket socket){
        this.socket=socket;
    }
    //线程执行操作,响应客户端的请求
    @Override
    public void run(){
        InputStream is=null;
        InputStreamReader isr=null;
        BufferedReader br=null;
        OutputStream os=null;
        PrintWriter pw=null;

        try{
            //3,获取输入流,用来读取客户端所发送的登录信息
             is=socket.getInputStream();
             isr=new InputStreamReader(is);
             br=new BufferedReader(isr);//为输入流添加缓冲
            String info=null;
            while ((info=br.readLine())!=null){//读取数据不为空,循环读取
                System.out.println(&quot;我是服务器,客户端说:&quot;&amp;#43;info);
            }

            //4,获取输出流,用来响应客户端的请求
            os=socket.getOutputStream();
            pw=new PrintWriter(os);//包装为打印流
            pw.write(&quot;欢迎哟,思密达~~·&quot;);
            pw.flush();//将缓冲输出
            socket.shutdownOutput();//关闭输出流

        }catch (Exception e){

        }finally {
            //5,关闭相关的资源
            try {
                pw.close();
                os.close();
                br.close();
                isr.close();
                is.close();
                socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }
}

服务端代码:

/**
 * Created by LiuHuiChao on 2016/3/9.
 * 基于TCP协议的socket通信,实现用户登录
 * 服务器端
 */
public class ServerSocketClass {
    public static void main(String[] args)throws Exception {
        //1,创建一个服务器端socket,即serverSocket,指定绑定的端口,并监听此端口
        ServerSocket serverSocket=new ServerSocket(8888);
        Socket socket=null;
        //2,调用accept方法等待客户端的连接
        System.out.println("----服务器即将启动----前方高能---");
        int ClientCount=0;
        while (true){

            //调用accept方法,等待客户端的连接
            socket=serverSocket.accept();
            //创建一个新的线程
            ServerThread st=new ServerThread(socket);
            //启动线程
            st.start();//启动新线程
            ClientCount&#43;&#43;;
            System.out.println("客户端的数量:"&#43;ClientCount);
            InetAddress address=socket.getInetAddress();
            System.out.println("当前客户端的IP:"&#43;address.getHostAddress());
        }
        //serverSocket.close();
    }
}

客户端代码:

/**
 * Created by LiuHuiChao on 2016/3/9.
 * 客户端
 */
public class ClientServerClass {
    public static void main(String[] args)throws Exception {
        //1,创建一个Socket,指定服务器地址和端口
        Socket socket=new Socket("localhost",8888);
        //2,获取输出流,用来向服务器端发送信息
        OutputStream os=socket.getOutputStream();
        PrintWriter pw=new PrintWriter(os);//将输出流包装成打印流
        pw.write("用户名:admin;密码:123");
        pw.flush();
        socket.shutdownOutput();//关闭输出流
        //3,获取输入流,并读取服务器端的响应信息
        InputStream is=socket.getInputStream();
        BufferedReader br=new BufferedReader(new InputStreamReader(is));
        String info=null;
        while ((info=br.readLine())!=null){//读取数据不为空,循环读取
            System.out.println("我是客户端,服务器端说:"&#43;info);
        }
        //4,关闭其他相关资源
        br.close();
        is.close();
        pw.close();
        os.close();
        socket.close();
    }
}

网络编程java多线程socket

因为水平有限,难免有疏忽或者不准确的地方,希望大家能够直接指出来,我会及时改正。一切为了知识的分享。

后续会有更多的精彩的内容分享给大家。