关于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()即可发送啊,搞不懂搞不懂,这样我的握手协议怎么做啊??

时间: 2024-10-02 04:21:27

关于java socket的问题的相关文章

Java socket编程入门

编程 第一章:学习提示 我适合学习这份教程吗 Socket提供了两台计算机之间进行通讯的机制,在James Gosling注意Java语言之前就已经很闻名了.Java语言使你更简单有效的使用Socket开发而无需了解操作系统的底层机制.大部分讨论Java编码的书籍都没有涉及这一主题,或者是只是"点到为止",留给读者大量的想象空间.这份教程就是让你了解在你的Java代码中如何更有效的使用Socket所需的知识.包含以下内容: •什么是Socket •它位于你的应用程序的哪些地方 •能正常

Java socket编程入门[1]

编程 第一章:学习提示 我适合学习这份教程吗 Socket提供了两台计算机之间进行通讯的机制,在James Gosling注意Java语言之前就已经很闻名了.Java语言使你更简单有效的使用Socket开发而无需了解操作系统的底层机制.大部分讨论Java编码的书籍都没有涉及这一主题,或者是只是"点到为止",留给读者大量的想象空间.这份教程就是让你了解在你的Java代码中如何更有效的使用Socket所需的知识.包含以下内容:•什么是Socket•它位于你的应用程序的哪些地方•能正常运行的

用Java Socket开发支持上千个并发的小型服务器(上)

Java Socket 套接字(socket)为两台计算机之间的通信提供了一种机制,在JamesGosling注意到Java语言之前,套接字就早已赫赫有名.该语言只是让您不必了解底层操作系统的细节就能有效地使用套接字. 1客户机/服务器模型 在饭店里,菜单上各种具有异国情调的食品映入你的眼帘,于是你要了一份pizza.几分钟后,你用力咀嚼浇着融化的乳酪和其他你喜欢的配料的热pizza.你不知道,也不想知道:侍者从那里弄来了pizza,在制作过程中加进了什么,以及配料是如何获得的. 上例中包含的实

java socket多线程的时间问题

问题描述 java socket多线程的时间问题 各位大神你们好, 我正在用java写一个接收服务器数据并进行统计的程序, 我用的是多线程socket. 该程序要求能够每秒钟接收几千条数据, 数据中包含value和timestamp以及其他字段. 每个数据通过单独的连接发送, 接收之后统计每秒的钟数据的最大值与平均值(指的是数据中所含有的"value"字段的值), 并将其存储到本地. 但是使用多线程时我有个疑问, 就是怎么判断是否到了1秒. 如果使用本地时钟计算肯定会与服务器有出入,

Java Socket聊天室编程(一)之利用socket实现聊天之消息推送_java

相关阅读:Java Socket聊天室编程(二)之利用socket实现单聊聊天室 网上已经有很多利用socket实现聊天的例子了,但是我看过很多,多多少有一些问题存在. 这里我将实现一个比较完整的聊天例子,并解释其中的逻辑. 由于socket这一块比较大,所以我将分出几篇来写一个比较完整的socket例子. 这里我们先来实现一个最简单的,服务器与客户端通讯,实现消息推送的功能. 目的:服务器与客户端建立连接,客户端可以向服务器发送消息,服务器可以向客户端推送消息. 1,使用java建立socke

Java socket字节流传输示例解析_java

本文为大家分享了Java socket字节流传输示例,供大家参考,具体内容如下 服务端server端:  package com.yuan.socket; import java.io.*; import java.net.ServerSocket; import java.net.Socket; /** * Created by YUAN on 2016-09-17. */ public class TalkServer4Byte { private ServerSocket server;

Java Socket实现客户端服务画面同步,报错

问题描述 Java Socket实现客户端服务画面同步,报错 java.net.ConnectException: Connection refused: connect at java.net.DualStackPlainSocketImpl.connect0(Native Method) at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79) at java.net.Abstra

java socket 编程遇到的问题

问题描述 最近初步学习java socket 编程的时候遇到一个问题就是,当客户端向服务端发送数据时,会出现不能输入也不能,程序卡住的现象,尤其是中文,最多输入两行,控制台就不能再输入数据(客户端输入是用system.in来从键盘获取数据).英文字符还好一些,但也会出现此种状况,百思不得其解!代码如下:server:package dragon.socket;import java.io.BufferedReader;import java.io.IOException;import java.

java Socket实现简单在线聊天(一)

最近的项目有一个在线网页交流的需求,由于很久以前做过的demo已经忘记的差不多了,因此便重新学习一下. 我计划的大致实现步骤分这样几大步: 1.使用awt组件和socket实现简单的单客户端向服务端持续发送消息: 2.结合线程,实现多客户端连接服务端发送消息: 3.实现服务端转发客户端消息至所有客户端,同时在客户端显示: 4.把awt组件生成的窗口界面改成前端jsp或者html展示的界面,java socket实现的客户端改为前端技术实现. 这里首先实现第一步的简单功能,难点在于: 1.没有用过

java socket 传递的.dit文件怎么查看才能没有乱码?

问题描述 java socket 传递的.dit文件怎么查看才能没有乱码? java socket 传递一个对象到.dit文件怎么查看才能没有乱码? 解决方案 http://blog.chinaunix.net/uid-24186189-id-2623970.html 解决方案二: .dit文件是干嘛的?电子字典里面用的? socket接收端接收到数据后是否有对数据进行处理还是就保存成文件然后再使用?如果是保存成文件那么乱码就应该是你的文件问题或者打开文件的应用的问题 如果是对接收到的数据进行处