文档章节

java网络编程01

zhchl2010
 zhchl2010
发布于 2015/09/21 13:44
字数 869
阅读 13
收藏 0
/////////////////简单版////////
public static void main(String[] args) {
        /*客户端通过Socket链接服务端*/
        Socket s=null;
        try {
            s=new Socket("127.0.0.1",5858);
            PrintWriter out=new PrintWriter(s.getOutputStream(),true);
            out.println("hello1!");
            
            BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
            String str=br.readLine();
            System.out.println(str);
        }catch(UnknownHostException e){
            e.printStackTrace();
        }catch (Exception e) {
            e.printStackTrace();
        }finally{
            try {
                if(s!=null) s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    /*java网络编程步骤:
     * 1.建立服务端和客户端
     * 2.实现服务端
     * 3.在服务器端接收客户端的链接
     * 4.客户端与服务端进行通信*/
    public static void main(String[] args) {
        /*创建服务端就是就是创建服务端Socket,Socket注意需要关闭
         * */
        ServerSocket ss=null;
        Socket s=null;
        try {
            ss=new ServerSocket(5858);//端口号不小于1024(系统保留),最大65355
            System.out.println("Server is run!");
            while(true){//服务端不能停止,死循环
                try {
                    s=ss.accept();    //接收客户端的请求
                    String name=s.getInetAddress().getHostAddress()+":"+s.getPort();
                    //System.out.println(s.getInetAddress()+":"+s.getPort()+"\thave Connected Server!");
                    BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
                    String str=br.readLine();
                    System.out.println(name+":"+str);
                    
                    PrintWriter out=new PrintWriter(s.getOutputStream(),true);
                    out.println("have receive clent info!");
                } finally{
                    if(s!=null){
                        s.close();
                        System.out.println(s+"out line");
                    }
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    /////////////////////////////////////////////////
    public static void main(String[] args) {
        Socket s=null;
        BufferedReader sbr=null;
        try {
            s=new Socket("127.0.0.1",5858);
            sbr=new BufferedReader(new InputStreamReader(System.in));
            PrintWriter out=new PrintWriter(s.getOutputStream(),true);
            BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
            String str=null;
            while((str=sbr.readLine())!=null){
                out.println(str);
                String rs=br.readLine();
                if(rs.equalsIgnoreCase("disconnected")){
                    break;
                }
                System.out.println(rs);
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(s!=null) s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(sbr!=null) sbr.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    public static void main(String[] args) {
        ServerSocket ss=null;
        Socket s=null;
        try {
            ss=new ServerSocket(5858);
            System.out.println("Server is run succseful");
            try {
                while(true){
                    s=ss.accept();
                    String name=s.getInetAddress().getHostAddress()+":"+s.getPort();
                    System.out.println(name+" has connected");
                    BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
                    PrintWriter out=new PrintWriter(s.getOutputStream(),true);
                    String str=null;
                    while((str=br.readLine())!=null){
                        if(str.equalsIgnoreCase("quit")){//关闭释放资源
                            out.println("disconnected");
                            break;
                        }
                        System.out.println(name+":"+str);
                        out.println(str);
                    }
                    System.out.println(name+"is out line");
                }
                
            } catch (IOException e) {
                e.printStackTrace();
            }finally{
                if(s!=null) s.close();
                    
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(ss!=null) ss.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    ///////////////////////////支持启动
    public class Client {

    private Socket s;
    private BufferedReader br;
    private PrintWriter out;
    private boolean flag=true;
    public static void main(String[] args) {
        new Client().startup();
    } 
    
    public void startup(){
        BufferedReader sbr=null;
        try {
            s=new Socket("127.0.0.1",5858);
            sbr=new BufferedReader(new InputStreamReader(System.in));
            PrintWriter out=new PrintWriter(s.getOutputStream(),true);
            br=new BufferedReader(new InputStreamReader(s.getInputStream()));
            out.println("hello");
            new Thread(new ClientThread()).start();
            String str=null;
            while(flag&&(str=sbr.readLine())!=null){//问题:假如客户端不输入内容,就无法获取服务端内容,需要写入线程
                out.println(str);
                
            }
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(s!=null) s.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(sbr!=null) sbr.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
    
    private void receive(){
        try {
            String rs=br.readLine();
            if(rs.equalsIgnoreCase("disconnected")){
                flag=false;
                System.out.println("点击回车退出");
            }
            System.out.println(rs);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
    private class ClientThread implements Runnable{
        @Override
        public void run() {
            while(true){
                if(!flag){
                    break;
                }    
                receive();
            }
        }
    }
    
    server.java
    private List<ServerThread> clients=null;//存储连接的客户端

    public static void main(String[] args) {
        new Server().stratup();
    }
    
    private void stratup(){
        ServerSocket ss=null;
        Socket s=null;
        String name=null;
        
        try {
            ss=new ServerSocket(5858);
            clients=new ArrayList<ServerThread>();
            System.out.println("Server is run succseful");
            
            while(true){
                s=ss.accept();
                ServerThread st=new ServerThread(s);
                new Thread(st).start();
            }
            
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(ss!=null) ss.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    } 
    
    private class ServerThread implements Runnable{
        private Socket s;
        private BufferedReader br;
        private PrintWriter out;
        private String name;
        boolean flag=true;
        
        public ServerThread(Socket s) throws IOException{
            this.s=s;
                br=new BufferedReader(new InputStreamReader(s.getInputStream()));
                out=new PrintWriter(s.getOutputStream(),true);
                String str=br.readLine();
                name=str+"["+s.getInetAddress().getHostAddress()+":"+s.getPort()+"]";
                //System.out.println(name+" has connected");
                clients.add(this);//每一个客户端连接就加入List中
                send(name+"上线了");//通知其他人新人上线了
        }
        
        private void send(String msg){
            for(ServerThread st:clients){
                st.out.println(msg);
            }
        }
        private void receive() throws IOException{//抛出异常,留给下一级捕获
            String str=null;
            while((str=br.readLine())!=null){
                if(str.equalsIgnoreCase("quit")){//关闭释放资源
                    this.stop();
                    
                    out.println("disconnected");
                    break;
                }
                System.out.println(name+":"+str);
                send(name+":"+str);//群发
            }
            System.out.println(name+"is out line");
        }
        
        public void stop(){
            clients.remove(this);
            System.out.println(name+"is out line");
            flag=false;
            send(name+"已经下线了");
        }
        @Override
        public void run(){
        
            try {
                while(true){
                    if(!flag) break;
                    receive();
                }
            }catch (SocketException e) {
                stop();
            } catch (IOException e) {
                e.printStackTrace();
            }finally{
                try {
                    if(s!=null) s.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }


© 著作权归作者所有

上一篇: java网络编程02
下一篇: Servlet初步
zhchl2010
粉丝 3
博文 80
码字总数 77710
作品 0
成都
程序员
私信 提问
突击javaweb项目整合开发

https://github.com/maxliaops/Java_Web_Examples.git Java_Web_Examples 《实战突击:Java Web项目整合开发》源码 01 - 都市供求信息网 02 - 物流配货网 03 - 编程爱好者博客地带 04 - 明日...

guorongjin
2016/10/09
0
0
JAVA区块链项目实战视频课程

课程介绍 全国首套,基于java的区块链实战教程。目的是让更多的java编程者了解区块链,掌握区块链开发。 1、区块链理论:以node.js例子区块链原理有深刻理解; 2、区块链java实战:深刻理解区...

小红牛
2018/09/14
0
0
java servic wrapper jvm启动五遍后就停止

STATUS | wrapper | 2013/04/03 12:01:35 | Launching a JVM... INFO | jvm 1 | 2013/04/03 12:01:36 | there are all ok ERROR | wrapper | 2013/04/03 12:01:36 | JVM exited while loadin......

这个世界不真实
2013/04/03
1K
1
什么是Java语言?java语言简介

Java是由Sun Microsystems公司于1995年5月推出的Java程序设计语言(以下简称Java语言)和Java平台的总称。用Java实现的HotJava浏览器(支持Java applet)显示了Java的魅力:跨平台、动态的W...

阿秀a
2010/10/19
0
0
14-1 16 Tomcat jdk 安装

Tomcat是Apache软件基金会(Apache Software Foundation)的Jakarta项目中的一个核心项目,由Apache、Sun和其他一些公司及个人共同开发而成。 java程序写的网站用tomcat+jdk来运行 tomcat是一...

阿想
2017/11/03
9
0

没有更多内容

加载失败,请刷新页面

加载更多

Nginx 快速安装详解

一、Nginx Nginx (engine x) 是一个高性能的HTTP和反向代理web服务器,同时也提供了IMAP/POP3/SMTP服务。Nginx是由伊戈尔·赛索耶夫为俄罗斯访问量第二的Rambler.ru站点(俄文:Рамбле...

网络小虾米
3分钟前
2
0
技术分享 | slave_relay_log_info 表认知的一些展开

作者:胡呈清 slave_relay_log_info 表是这样的: mysql> select * from mysql.slave_relay_log_info\G *************************** 1. row *************************** Number_of_lin......

爱可生
5分钟前
1
0
nginx配置http访问自动跳转到https

server {listen 80;server_name www.域名.com;rewrite ^(.*) https://$server_name$1 permanent;}server {listen 443;server_name www.域名.com;root /home/www;ssl on;......

很好亦平凡ms
5分钟前
1
0
SpreadJS:一款中国研发的类Excel开发工具,功能涵盖Excel的 95% 以上

Excel 作为一款深受用户喜爱的电子表格工具,借助其直观的界面、出色的计算性能、数据分析和图表,已经成为数据统计领域不可或缺的软件之一。 基于Excel对数据处理与分析的卓越表现,把Excel...

葡萄城技术团队
6分钟前
1
0
用javafx框架tornadofx做了个天气预报的程序

class WeatherApp : App(WeatherView::class)class WeatherView : View("十五天天气预报") { val weatherVM: WeatherViewModel by inject() val controller: WeatherController by......

oschina4cyy
9分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部