快精灵印艺坊 您身边的文印专家
广州名片 深圳名片 会员卡 贵宾卡 印刷 设计教程
产品展示 在线订购 会员中心 产品模板 设计指南 在线编辑
 首页 名片设计   CorelDRAW   Illustrator   AuotoCAD   Painter   其他软件   Photoshop   Fireworks   Flash  

 » 彩色名片
 » PVC卡
 » 彩色磁性卡
 » 彩页/画册
 » 个性印务
 » 彩色不干胶
 » 明信片
   » 明信片
   » 彩色书签
   » 门挂
 » 其他产品与服务
   » 创业锦囊
   » 办公用品
     » 信封、信纸
     » 便签纸、斜面纸砖
     » 无碳复印纸
   » 海报
   » 大篇幅印刷
     » KT板
     » 海报
     » 横幅

关于java socket的问题


要做成这样的:

客户端访问服务器ip和port,服务器立刻发送welcome消息,然后客户端根据welcome消息判定是否是想要连接的服务器和端口,

假如是则开始发送数据,数据包括开始和结束的校验。服务器端发送welcome消息后开始接收数据,直到结束。蛮简朴的事TMD我怎么就搞不定。

CLIENT:

package com.ces.mytest.socket;

import java.net.*;import java.io.*;

public class ClientThread extends Thread {    private String ipStr = "";    private int port;    public ClientThread(String ipStr, int port) {        this.ipStr = ipStr;        this.port = port;    }

    public void run() {        try {            Socket client = new Socket(ipStr, port);            BufferedReader read = new BufferedReader(new InputStreamReader(client.getInputStream()));            BufferedWriter write = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));

            if ("欢迎".equals(read.readLine())) {                System.out.println("校验准确");

                write.write("开始");                write.newLine();                write.write("数据");                write.newLine();                write.write("结束");                write.newLine();                write.flush();

                System.out.println("发送完毕");            }

            write.close();            read.close();            client.close();        } catch (UnknownHostException ex) {            ex.printStackTrace();        } catch (IOException ex) {            ex.printStackTrace();        }    }

    public static void main(String[] args) {        Thread client = new ClientThread("127.0.0.1",10020);        client.start();    }

}

SERVER:

package com.ces.mytest.socket;

import java.net.*;import java.io.*;

public class ServerThread extends Thread {    private int port;    public ServerThread(int port) {        this.port = port;    }

    private boolean stop = false;

    public void run() {        try {            ServerSocket server = new ServerSocket(port);            while (!stop) {                Socket client = server.accept();                BufferedReader read = new BufferedReader(new InputStreamReader(client.getInputStream()));                BufferedWriter write = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));                                System.out.println("发送欢迎信息");                                write.write("欢迎");                write.flush();

//                String lineStr = read.readLine();//                if ("开始".equals(lineStr)) {//                    System.out.println("开始接受数据!");////                    while (true) {//                        lineStr = read.readLine();//                        if ("结束".equals(lineStr)) {//                            break;//                        } else {//                            System.out.println("数据是" + lineStr);//                        }//                    }//                }

                write.close();                read.close();                client.close();            }

        } catch (IOException ex) {            ex.printStackTrace();        }    }

    public static void main(String[] args) {        Thread server = new ServerThread(10020);        server.start();    }

    public boolean isStop() {        return stop;    }

    public void setStop(boolean stop) {        this.stop = stop;    }}

只要我将ServerThread类的String lineStr = read.readLine();的注释去掉,程序肯定出问题,什么问题呢?分析发现ServerThread的Output流必须等write.close()执行完才发送,而read.readLine()程序就会停在那里,所谓的block程序,可参考上明明说write.flush()即可发送啊,搞不懂搞不懂,这样我的握手协议怎么做啊??




返回类别: 教程
上一教程: Java的破解和反破解之道
下一教程: 建构大型商业系统所要考虑的事项

您可以阅读与"关于java socket的问题"相关的教程:
· 上次java socket 的问题已解决,这次关于trigger问题了
· 关于JAVAMAIL处理中文附件的问题
· [JAVA]变量作用域的问题
· 在java开发过程中常常遇到数据类型的问题
· JAVAMAIL发信的连接SMTP验证的问题
    微笑服务 优质保证 索取样品