java socket长连接循环读取数据

用ip端口密码里连接上服务端控制台,然后一直从服务端控制台读取数据,当读取到某一特定字符的时候干什么业务,有一个问题就是,只要连接上他就一直读取,阻塞在循环内,如果后续需要发送心跳包只有另外一个类里面隔多久发送一条命令,当读取类读取到这个命令的时候发送一条信息给服务端保持连接,不然过20分钟左右就断了,请问有什么更好的方法实现,一直监听数据,读到特定字符数据时实现特定业务,而不是一直阻塞式读取

qq_42235984
Peak丶 额 ,这个现在已实现,但是第二个问题已随之而来那就是如何保证长连接每天能正常读取
大约一年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
Java Socket长连接读取数据

需求:读取服务端日志,读取到特定的值做特定的操作提示 ,只要开启就一直读取 目前是写的Socket死循环读取,但当特定的值多了之后,再服务端日志中同时出现几个特定的值,那运行效率就会变低,请问这种程序如何设计

java socket 长连接奇怪的问题

我有一个类,负责通过SOCKET长连接与服务器端通讯。 这个循环读取一个队列来发送。 问题来了,在本类的MAIN方法中向队列中添加数据,就可以发送出去,在SERVLET中,通过HTTP请求添加,就是发送不出去!请大家帮忙看看,谢谢。下面是这个主要类的代码。 /** * */ package com.dianshangwang.lianhepayfront.service; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.io.UnsupportedEncodingException; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketException; import java.util.HashMap; import java.util.LinkedList; import java.util.Map; import java.util.Queue; import org.apache.log4j.BasicConfigurator; import org.apache.log4j.Logger; import com.dianshangwang.lianhepayfront.global.Config; import com.google.gson.JsonObject; import com.google.gson.JsonParser; /** * @author lay * @date 2013年11月4日 */ public class IcardpayClient { private static Logger log = Logger.getLogger(IcardpayClient.class); private static Socket socket; private static BufferedReader reader; private static PrintWriter writer; private static Thread sendThread; private static Thread receiveThread; private static Thread monitorThread; private static boolean isRunning = false; /** * 心跳计数器 若此值与当前时间戳值小于60000则认定断线,进行重联操作 */ private static Long heartbeatTimestamp = System.currentTimeMillis(); private static IcardpayClient instance = new IcardpayClient(); private IcardpayClient() { } public static IcardpayClient getInstance() { return instance; } public static void main(String[] args) { BasicConfigurator.configure(); IcardpayClient client = new IcardpayClient(); client.start(); MsgQueue.sendQueue.add("{\"agentNo\":\"A10342hp\",\"tradeType\":\"256\",\"sessionId\":\"1\"}"); } public void start() { init(); sendThread = new Thread(new SendThread());// 启动读线程 receiveThread = new Thread(new ReceiveThread());// 启动收线程 monitorThread = new Thread(new MonitorThread()); // 启动监视线程 sendThread.setName("icardpay-send-thread"); receiveThread.setName("icardpay-receive-thread"); monitorThread.setName("icardpay-monitor-thread"); // sendThread.setDaemon(true); // receiveThread.setDaemon(true); // monitorThread.setDaemon(true); sendThread.start(); log.info("SOCKET发送线程开启!"); receiveThread.start(); log.info("SOCKET接收线程开启!"); // monitorThread.start(); // log.info("SOCKET监视线程开启!"); } public void restart() { stop(); init(); } public void stop() { isRunning = false; } private void init() { socket = new Socket(); try { socket.setKeepAlive(true); socket.connect(new InetSocketAddress(Config.icardpayHost, Config.icardpayPort)); reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8")); writer = new PrintWriter(socket.getOutputStream()); heartbeatTimestamp = System.currentTimeMillis(); log.info("已创建与支付通的SOCKET连接!"); isRunning = true; } catch (SocketException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void write(String msg) { writer.println(msg); writer.flush(); log.info(Thread.currentThread().getName() + "发送:" + msg); } private String read() throws IOException { String msg = reader.readLine(); if (msg != null) { log.info("接收:" + msg); } return msg; } class SendThread implements Runnable { @Override public void run() { while (isRunning) { if (!MsgQueue.sendQueue.isEmpty()) { String v = MsgQueue.sendQueue.poll(); write(v); } try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } } } } class ReceiveThread implements Runnable { @Override public void run() { while (isRunning) { String content = null; try { content = read(); } catch (IOException e1) { log.error("SOCKET读取异常,将重新启动。。。", e1); restart(); continue; } if (null == content || content == "") { continue; } JsonObject obj = new JsonParser().parse(content).getAsJsonObject(); if (obj.has("tradeType") && "0".equals(obj.get("tradeType").getAsString())) { // 收到心跳包, 刷新计数器 heartbeatTimestamp = System.currentTimeMillis(); continue; } if (!obj.has("sessionId")) { log.info("收到未标识的包:" + obj.toString()); continue; } String id = obj.get("sessionId").getAsString(); if (MsgQueue.listeners.containsKey(id)) { MsgQueue.listeners.get(id).received(content); MsgQueue.listeners.remove(id); } else { log.info("接收到过期包:" + content); } try { Thread.sleep(100); } catch (InterruptedException e) { // 忽略 } } } } class MonitorThread implements Runnable { String heartbeat = "{\"agentNo\":\"A10342hp\",\"tradeType\":\"0\"}"; @Override public void run() { while (isRunning) { if (System.currentTimeMillis() - heartbeatTimestamp >= 60000) { // SOCKET已失效 restart(); } // 发送心跳包 write(heartbeat); try { Thread.sleep(5000); } catch (InterruptedException e) { // 忽略 } } } } }

java Socket长连接读取日志程序设计

需求:读取服务端日志,读取到特定的值做特定的操作提示 ,只要开启就一直读取 目前是写的Socket死循环读取,但当特定的值多了之后,再服务端日志中同时出现几个特定的值,那运行效率就会变低(已经发生过,让人以为是延迟),请问这种程序如何设计 目前的思路是:读到特定的字符重启一个线程去处理相关业务,这样多了也就不会发生这种延迟问题,但我对多线程,并发 这块不是很熟悉,特别是处理共享资源的时候,一个不小心。就会出问题,想问下各位有没有更好的方法,比如有已经封装好的框架,或者有没有比较全面的资料或博客连接,我这边学习一下,因为网上的资料知识大部分比较碎片化了,谢谢

java socket读取服务端返回数据流

描述:发送一条命令给服务端,读取服务端返回信息并格式化显示 问题:如何读取反馈的指定信息,也就是发送之后立马反馈的信息,不包括后面服务端加载的信息 解决:现在我用的是readLine()读取部分命令发送反馈信息以结尾固定的格式指定退出循环,退出读取,部分命令这个方法确实能行,部分命令这个不行,因为部分命令反馈的信息结尾不是一个固定的格式,请问如何才能读取到自己想要的信息

java socket客户端一直监听服务端返回数据

连接服务端之后,一直要监听服务端的加载信息,当检测到特定格式的数据,干什么事。目前是用readLine!=null循环读取数据的,关闭是用ajax发一条命令给服务端,当检测到这条命令时,退出循环读取,但是这个方法是阻塞的,及不方便,如发送心跳包,有什么更好的方法实现吗

java socket 多次反复通信

我用java socket实现简单的通讯功能,在做登陆的时候,客户端将用户名密码读取出来 发送给服务器(这是第一步),服务器读取信息后校验(这是第二步),校验后发送给客户端,客户端读取是否登陆成功的消息(这是第三步),但是,第一步第二步都没问题,但客户端无法将服务器再次发送的消息读取出来,下面是我的部分代码,我不知道怎么实现这种多次反复通信的问题,希望大家不吝赐教。 服务器代码: output = new OutputStreamWriter(socket.getOutputStream()); input = new DataInputStream(socket.getInputStream()); byte [] b2=new byte[1024]; int len=input.read(b2); String str = new String(b2,0,len); //读取用户名密码 System.out.println("客户端接收到的用户名密码:"+str); //此处校验代码省略,假设用户名密码正确 output.write("reponse:1"); //发送给客户端登陆消息 System.out.println("服务器消息:登陆消息已发给客户端"); 服务器控制台: 已启动监听,调用线程进入等待阶段…… 服务器消息,客户端已响应 服务器消息:服务器已经建立与客户端的连接,客户端ip:/127.0.0.1 已启动监听,调用线程进入等待阶段…… 客户端接收到的用户名密码:command:1;userName:username;passWord:password 服务器消息:登陆消息已发给客户端 客户端代码: input = new BufferedReader( new InputStreamReader(socket.getInputStream())); DataOutputStream output = new DataOutputStream(socket.getOutputStream()); byte[] b = MainWindow.DATA.getBytes(); //将用户名密码转化为byte output.write(b); //发送给服务器 System.out.println("用户名,密码信息已发送"); output.flush(); String str = input.readLine(); //读取服务器消息 System.out.println("客户端消息:已读取到登录信息"); if(str.equals("reponse:1")){ LoginDialogs.AUTH = true; //授予客户端登录权限 } System.out.println(LoginDialogs.AUTH); 客户端控制台: 已连接 登陆按钮消息:已点击 用户名,密码信息已发送

socket循环发送请求并读取响应时,循环到第二次之后就读不到响应内容

问题描述: 业务需求是有一个报文数组,我遍历该数组,每取到一个报文串,便通过socket发送至服务端处理,然后读取服务端响应的报文。但是经过反复测试,每次循环第一次的流程是正常的,但是循环到第二次之后,却读不到响应的报文(内容为空)。求各路神仙大虾帮我看看(PS:我看过网上很多的帖子,有的人说socket输入流就像一个一次性的杯子,只能使用一次。但是按这样的话,我岂不是每次发送都需要建立socket连接?这样太消耗资源了吧)。 这是我的业务逻辑代码 public void sendReq(String[] RequestXml) throws Exception{ Messenger messenger = new Messenger(SERVERIP, SERVERPORT, TIMEOUT, "UTF-8"); for (String requestXML : RequestXml) { String response = messenger.sendReq(requestXML); System.out.println(response); } messenger.close(); } 下面是我的socket发送类代码 public class Messenger { private static final Logger logger = Logger.getLogger(Messenger.class); private Socket soc; private PrintWriter pw; private BufferedReader sin; private String charset; /** * 初始化连接 * @param serverIp 连接IP * @param serverPort 连接端口 * @param timeout 超时时间 * @param charset 编码格式 * @throws Exception */ public Messenger(String serverIp, int serverPort, int timeout, String charset) throws Exception { this.soc = new Socket(serverIp, serverPort); this.charset = charset; soc.setSoTimeout(timeout); soc.setKeepAlive(true); } /** * 发送报文 * @param reqXML 待发送的报文 * @return */ public String sendReq(String reqXML) { StringBuffer responseStr = new StringBuffer(""); PrintWriter pw = null; BufferedReader sin =null; try { pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(soc.getOutputStream(), charset))); sin = new BufferedReader(new InputStreamReader(soc.getInputStream(), charset)); logger.info("【开始发送报文】"); pw.println(reqXML); pw.flush(); logger.info("【报文发送完毕】"); String str; while((str = sin.readLine()) != null) { responseStr.append(str); } logger.info("【成功读取响应报文】"); } catch(Exception e) { logger.warn("【读取响应报文时出错】" + e); } finally { if (pw != null) { pw.close(); } if (sin != null) { try { sin.close(); } catch (IOException e) {} } } return responseStr.toString(); } //关闭连接 public void close() { if (pw != null) { pw.close(); } if (sin != null) { try { sin.close(); } catch (IOException e) {} } if (soc != null) { try { soc.close(); } catch (IOException e) {} } logger.info("【关闭SOCKET连接】"); } }

Java Socket 读取TCP服务端数据包不完整

Java Socket 读取TCP服务端数据包不完整:除了利用数据包大小循环读取输入流的得到完整的数据外,还有其他什么方法? 数据包在网络传输的过程中,数据传递到客户端基本处于“无序”态。除了开辟一块内存按数据包的顺序存放外,还有其他更好的方案么?

关于java 不能完全读取socket二进制流的问题(数据量越大问题就越严重)

我在java中用socket读取server端发过来的二进制流,从包头前面11个字节中读取包体的字节总数,然后再循环读取包体的字节数,但当server端的数据字节比较大时就不能完全读过来 ,如从server端发送了 3万个字节,这时client端程序就会不能完全读出server端的字节,可能只能读2万多个; 当字节数少于2000 以下时,就基本没有出现过问题。 我把程序贴出来,这段程序有什么问题么?接收大量的数据该如何处理为好? 想了很久,没想明白是怎么回事,望各位不吝赐教!!! public class SocketService { private static Socket socket; private static InputStream is; private static OutputStream os; private static BufferedInputStream br; public static byte[] getReceiveBytes(Catalog catalog,byte[] b) { byte[] receive_body_byte = {}; try { socket = new Socket(catalog.getPrivateTcpIp(), Integer.parseInt(catalog.getPrivateTcpIPPort())); is = new DataInputStream(socket.getInputStream()); os = new DataOutputStream(socket.getOutputStream()); os.write(b); br = new BufferedInputStream(is); // 包体长度 packlength。 String packlength = ""; // 先收11个字节,函数解析出数据包长度 byte[] encry_byte = new byte[11]; int sizeHead = br.read(encry_byte); for (int m = 0; m < sizeHead; m++) { if (m > 6) { packlength = packlength + Util.byte2HexStr(encry_byte[m]); } } receive_body_byte = new byte[Integer.parseInt(packlength, 16)]; // 接收剩下的字节 int size = br.read(receive_body_byte); //打印接收到的字节 System.out.println("\n-------接收到的字节总数是-------------- "+receive_body_byte.length); os.flush(); is.close(); os.close(); br.close(); } catch (Exception e) { System.out.print("**********Socket异常!!!!*********"+e.getMessage()); return null; } return receive_body_byte; } ========= 上面的程序不知哪里有问题,于是我就又优化了一下,代码如下,但遇到大数据还是不能全读出来=================== public class SocketService { private static Socket socket; private static InputStream is; private static OutputStream os; private static BufferedInputStream br; public static byte[] getReceiveBytes(Catalog catalog,byte[] b) { byte[] receive_body_byte = {}; try { socket = new Socket(catalog.getPrivateTcpIp(), Integer.parseInt(catalog.getPrivateTcpIPPort())); is = new DataInputStream(socket.getInputStream()); os = new DataOutputStream(socket.getOutputStream()); os.write(b); br = new BufferedInputStream(is); // 包体长度 packlength。 String packlength = ""; // 先收11个字节,函数解析出数据包长度 byte[] encry_byte = new byte[11]; int sizeHead = br.read(encry_byte); for (int m = 0; m < sizeHead; m++) { if (m > 6) { packlength = packlength + Util.byte2HexStr(encry_byte[m]); } } receive_body_byte = new byte[Integer.parseInt(packlength, 16)]; int size = 0 // 分次取server端的数据,即每次从流中取1024个字节,不足1024就一次取过来 while(true){ int a = receive_body_byte.length/1024; if(a>=1){ int last=0; Thread.sleep(280); for(int i=0;i<a;i++){ //Thread.sleep(50); byte[] btmp = new byte[1024]; br.read(btmp); getBytes(receive_body_byte,i*1024,btmp); last = last + i*1024; Thread.sleep(100); } //然后取剩余不足1024个的字节 int aa = receive_body_byte.length%1024; byte[] bmp = new byte[aa]; //Thread.sleep(200); if(aa!=0){ br.read(bmp); System.out.println(" aa------------"+aa); p(bmp); Thread.sleep(100); getBytes(receive_body_byte,a*1024,bmp); } break; }else{ br.read(receive_body_byte); break; } } //打印接收到的字节 System.out.println("\n-------接收到的字节总数是-------------- "+receive_body_byte.length); os.flush(); is.close(); os.close(); br.close(); } catch (Exception e) { System.out.print("**********Socket异常!!!!*********"+e.getMessage()); return null; } return receive_body_byte; }

使用Java socket让客户端与服务器建立连接后,服务器如何判断来自客户端的各类请求

初学java,目前写了一个服务端和一个客户端。大致了解了如何socket通信是如何操作的,并且初步实现了客户端和服务端的通信。也仅仅是是接受和返回简单的字符串。部分代码如下 public void run(){ try{ serverSocket=new ServerSocket(SERVER_PORT_ONE); System.out.println("serversocket已创建"); while(true){ clientSocket=serverSocket.accept(); System.out.println("监测到了socket"); receiveThread=new SocketThread(clientSocket); //开启新线程处理请求 receiveThread.start(); } }catch(IOException e){ System.out.println(e.getMessage()); } } ``` ``` 这是socket监听的代码。当服务器监听到了socket之后,开启一个新线程去处理。 socketthread类的run()方法来接受数据 public void run(){ String Command=null; String str=null; output.println("服务器已经接受你的连接\n"); while(true){ try{ str=null; str=input.readLine(); System.out.println("监测数据如下:"+str); }catch(IOException e){ System.out.println(e.getMessage()); } Command=str.trim().toUpperCase(); if(str==null || Command.equals("QUIT")) { break; } } try{ clientSocket.close();//关闭套接字 System.out.println("clientSocket已经断开连接"); }catch(IOException e){ System.out.println(e.getMessage()); } Command=null; } ``` 在while循环里面,服务端会不断读取来自客户端的内容,然后输出来。如果读到quit,就表示断开连接,并关闭socket。 ``` 现在的问题就是, 如果我的客户端的请求十分多样,比如发送语音,视频,图片或者数据给服务器进行处理,我的服务端必须做出相应的处理,请问如何做到这点啊。 我自己想的思路是客户端发送数据前先要发送一个header标签,表示想干什么。然后读取到了之后客户端再判断,然后分给不同的函数去处理。不知道这样好不好,如下所示。 while(true){ try{ str=null; str=input.readLine(); if(str.equals("图片")){ 图片相关函数(socket ); } if(str.equals("视频")){ 视频处理相关函数(socket ); } if(str.equals("数据")){ 数据处理相关函数(socket );//如各种算法 } System.out.println("监测数据如下:"+str); }catch(IOException e){ System.out.println(e.getMessage()); } Command=str.trim().toUpperCase(); if(str==null || Command.equals("QUIT")) { break; } 不知道是否可行。 第二个问题,我的服务器要主动推送数据给客户端该如何实现,肯定不能写在这个线程里面。写在其他地方我的类和函数如何得到这个线程里的socket呢。

java socket服务端多次发送请求的问题

具体的是这样的: 需要往一个给定ip和端口的服务端发送数据,假如服务端收到数据并返回“success”之后,那么就不再重复发送数据。如果socket连接超时或者服务端返回的信息不是"success",那么就每多几秒再次发送数据。时间例如是:5s,10s,20s,35s.... 最笨的办法是每次都启动一个socket线程处理,可以在一个线程中解决这个问题吗?具体怎么设计,请大神 帮忙指导。

java Socket 在客户端断开之后才可以接收到客户端发送的消息!

``` //客户端 public class Test { private static boolean is = true; public static void main(String[] args) throws IOException, InterruptedException { Socket socket = new Socket("127.0.0.1", 6677); System.out.println("链接成功"); Scanner scanner = new Scanner(System.in); while (is) { System.out.println("请输入!!!"); int n = scanner.nextInt(); switch (n) { case 1: OutputStream os = socket.getOutputStream(); os.write("hello world".getBytes()); os.flush(); // os.close(); // socket.close(); // IoUtil.IoClose(os); System.out.println("发送成功"); break; case 2: System.out.println("循环关闭"); is = false; break; default: is = false; System.out.println("输入错误---循环关闭"); break; } } } } ``` ``` //服务器端 太多了 就贴一部分 @Override public void run() { MessageThread messageThread = null; InputStream iss = null; InputStreamReader isr = null; BufferedReader br = null; while (is) { try { // 监听 Socket socket = serverSocket.accept(); System.out.println("链接成功"); iss = socket.getInputStream(); isr = new InputStreamReader(iss); br = new BufferedReader(isr); String len; StringBuffer sb = new StringBuffer(); while ((len = br.readLine()) != null) { sb.append(len); } System.out.println(sb.toString()); // iss.close(); // IoUtil.IoClose(br, isr, iss); SocketMap.put(sb.toString(), socket); /** * 开启接受消息的线程 */ messageThread = new MessageThread(socket); messageThread.start(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); messageThread.setFlag(false); } } ``` 大致代码就这些 问题出在 socket 可以链接成功 但是 客户端发送的消息要等 客户端断开链接之后才能接收到 或者 关闭客户端的输出流也可以! C#为客户端的时候也一样!

希望各位大佬能够解答困惑。Java socket客户端输出结束但不关闭流,服务器端如何判断传输完成?

客户端: ``` DataInputStream fis = new DataInputStream(new FileInputStream(f)); DataOutputStream ps = new DataOutputStream(socket.getOutputStream()); ps.writeUTF(f.getName()); ps.flush(); ps.writeUTF(name); ps.flush(); ps.writeLong((long) f.length()); ps.flush(); int bufferSize = 1023; byte[] buf = new byte[bufferSize]; while (true) { int read = 0; if (fis != null) { read = fis.read(buf); } if (read == -1) { System.out.println("文件传输结束"); break; } ps.write(buf, 0, read); } ps.flush(); ``` 服务器端: ``` try { DataInputStream is = new DataInputStream(socket.getInputStream()); OutputStream os = socket.getOutputStream(); //1、得到文件名 String path="E:\\"; String filename = is.readUTF(); path+=filename; String username = is.readUTF(); System.out.println("新生成的文件名为:"+path); FileOutputStream fos = new FileOutputStream(path); byte[] b = new byte[1023]; int length = 0; while((length=is.read(b))!=-1){ //2、把socket输入流写到文件输出流中去 fos.write(b, 0, length); System.out.println("还在写"); } fos.flush(); }catch(Exception e) { e.printStackTrace(); System.out.println("传输出错"); } ``` 为什么服务器端始终不跳出循环?服务器端如何判断客户端传输完成?

java socket客户端能不能单线程一次连接服务器然后进行多次对话?

像qq那样,客户端跟服务器都可以发多条消息,我在想客户端能不能通知下服务器自己的输出流有变化

Java Socket 外网连不上但是内网可以。 ADSL提供网络,没有路由器

各位朋友,问题较长,请耐心看我来详细描述一下: 服务端是一个JavaWEB的网站项目,里面有ServerSocket,用来接受客户端数据。客户端是Android程序,里面启动Socket后会循环发送数据。我在运行的时候用的是家里的电脑和自己的手机,如果都在一个局域网里(手机用WIFI)数据传输没有问题,如果切换到外网后(ADSL出来的网线连接电脑,手机用3G)用我电脑cmd命令ipconfig查到的PPP ip输入到手机浏览器中可以访问JavaWEB的网站,也就是说可以ping通这个ip地址。但是用手机发送socket数据到这个ip时,服务端会在accept()一直阻塞。我也想过可能是端口没有开放,但是如果我把Android端的socket不进行循环发送数据时(只发送一条数据)过20秒左右服务端会报错 java.net.SocketException: Connection reset,报错的地方是服务端接收到客户端数据后进行读取操作的一步(下面代码最后一行会报错) Socket s = new ServerSocket(7777).accept(); InputStream in = s.getInputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(in)); String response = br.readLine(); 用DEBUG查看会发现报错前s中有客户端的信息,比如客户端的ip地址和发送端口等。这是不是也可以证明服务器的端口已经开放。如果排出了端口和ip地址的问题。那我就彻底费解了。 还请各位好心的有经验的朋友们帮我参考一下,到底如何解决这个问题,谢谢大家 因为现在已经没有路由器所以应该不用端口转发,之前用路由器的时候也试过端口转发,是不行的,后来直接把路由器撤了。

socket通信中,socket建立连接后能进行长时间的反复读写操作吗?

服务端和客户端以socket建立连接进行通信,我想以单线程实现多文件传输,循环发送多个文件,只是对输入输出流进行打开和关闭,为什么第一个文件传完后进行第二个文件传输时会抛异常:Socket is closed?求高手指点迷津,难道一定要关闭socket然后重新连接吗?

java的socket编程问题:为什么客户端接收服务器的数据时会有空白数据项?

例如:03-17 07:02:00.330 1984-2007/? I/info﹕ client buff --> 0/20160316//早餐/123.0 03-17 07:02:00.340 1984-2007/? I/info﹕ insert expend_table 03-17 07:02:00.340 1984-2007/? I/info﹕ client buff --> 03-17 07:02:00.340 1984-2007/? I/info﹕ client buff --> 0/20160316//午餐/22.0 03-17 07:02:00.340 1984-2007/? I/info﹕ insert expend_table 03-17 07:02:00.340 1984-2007/? I/info﹕ client buff --> 03-17 07:02:00.340 1984-2007/? I/info﹕ client buff --> 0/20160316/22ss/服装/123.0 数据内容忽视。client buff是客户端接受到的数据 就是为什么会是一条有数据一条没有数据这样循环下去? 服务端代码: pw = new PrintWriter(s.getOutputStream()); Cursor c = dbManager.query(Constant.DATA_TABLE,"username=?",new String[]{username}); while (c.moveToNext()){ // client端发送数据的顺序: isIncome + "/" + date + "/" + title + "/" + content + "/" + money String title = c.getString(c.getColumnIndex("title")); String money = c.getString(c.getColumnIndex("money")); Long date = c.getLong(c.getColumnIndex("date")); String isIncome = c.getString(c.getColumnIndex("isIncome")); String content = c.getString(c.getColumnIndex("content")); String data = isIncome + "/" + date + "/" + title + "/" + content + "/" + money + '\n'; pw.println(data); pw.flush(); } String endFlag = username + "/end" + '\n'; pw.println(endFlag); pw.flush(); 客户端代码: br = new BufferedReader(new InputStreamReader(s.getInputStream())); String buff; while (!(buff = br.readLine()).endsWith(mUsername + "/end")) { // server端发送数据的顺序: isIncome + "/" + date + "/" + title + "/" + content + "/" + money String[] str = buff.split("/"); if (str.length == 5) { //确保接收的数据正确 ContentValues values = new ContentValues(); values.put("isIncome", str[0]); values.put("date", Long.valueOf(str[1])); values.put("title", str[2]); values.put("content", str[3]); values.put("money", str[4]); if ("0".equals(str[0])) { if (!dbManager.insert(Constant.EXPEND_TABLE, values)) { flag = false; break; } } else if ("1".equals(str[0])) { if (!dbManager.insert(Constant.INCOME_TABLE, values)) { flag = false; break; } } } } db.setTransactionSuccessful(); db.endTransaction();

关于java网络编程中获取输入流中数据的问题?

//服务器端接收消息的类。定制端口号为8888 serviceSocket = new ServerSocket(10000); //获取socket。这个方法是阻塞式的 socket = serviceSocket.accept(); inputStream = socket.getInputStream(); byte buf[] = new byte[1024]; int len = 0; len =inputStream.read(buf); //打印客户端的消息 System.out.println(new String(buf,0,len)); //向客户端生成响应 outputStream = socket.getOutputStream(); outputStream.write("收到".getBytes()); 使用如上代码没然后问题。服务端可以获取客户端的数据。客户端也可以获取服务端的响应。但如果把其中inputStream的读取数据方式改为如下: while((len=inputStream.read(buf))>0){ //此处拼接客户端的消息 } //在循环外向客户端相应 outputStream = socket.getOutputStream(); outputStream.write("收到".getBytes()); 此时就会出错。服务端无法获取客户端的数据。客户端也无法获取服务端的响应。通过一个循环来不断读取流中的数据是io流的通常做法。为什么这儿不行。。。求解。

如何把socket通讯接收到的数据放在缓存里,然后用另一个线程读取缓存来进行数据库的写入操作

先贴上nio通讯代码 ![图片说明](https://img-ask.csdn.net/upload/201904/30/1556596574_246874.jpg) ![图片说明](https://img-ask.csdn.net/upload/201904/30/1556596627_364570.jpg) 在 ![图片说明](https://img-ask.csdn.net/upload/201904/30/1556596702_350963.jpg) 这获取到通讯数据后,我想放在缓存里,然后另一个线程就负责读取缓存的数据进行数据库插入操作。在网上查过关于ehcache和redis之类的缓存框架,也考虑过是否可以用一个静态变量替代缓存,想问问各位大佬哪种实现起来比较简单并且靠谱并提供一个设计思路。万分感谢。!!!

2019 AI开发者大会

2019 AI开发者大会(AI ProCon 2019)是由中国IT社区CSDN主办的AI技术与产业年度盛会。多年经验淬炼,如今蓄势待发:2019年9月6-7日,大会将有近百位中美顶尖AI专家、知名企业代表以及千余名AI开发者齐聚北京,进行技术解读和产业论证。我们不空谈口号,只谈技术,诚挚邀请AI业内人士一起共铸人工智能新篇章!

实现简单的文件系统

实验内容: 通过对具体的文件存储空间的管理、文件的物理结构、目录结构和文件操作的实现,加深对文件系统内部功能和实现过程的理解。 要求: 1.在内存中开辟一个虚拟磁盘空间作为文件存储器,在其上实现一个简

MIPS单周期CPU-组成原理实验-华中科技大学

使用logisim布线完成的MIPS单周期CPU,可支持28条指令。跑马灯的代码已经装入了寄存器,可以直接开启时钟运行。

2019数学建模A题高压油管的压力控制 省一论文即代码

2019数学建模A题高压油管的压力控制省一完整论文即详细C++和Matlab代码,希望对同学们有所帮助

基于QT和OpenCV的五子棋实现源码

一个简单的五子棋应用,基于QT和OpenCV的实现源码,通过相邻棋子判断是否获胜,不包含人工智能算法,适合新手入门

Git 实用技巧

这几年越来越多的开发团队使用了Git,掌握Git的使用已经越来越重要,已经是一个开发者必备的一项技能;但很多人在刚开始学习Git的时候会遇到很多疑问,比如之前使用过SVN的开发者想不通Git提交代码为什么需要先commit然后再去push,而不是一条命令一次性搞定; 更多的开发者对Git已经入门,不过在遇到一些代码冲突、需要恢复Git代码时候就不知所措,这个时候哪些对 Git掌握得比较好的少数人,就像团队中的神一样,在队友遇到 Git 相关的问题的时候用各种流利的操作来帮助队友于水火。 我去年刚加入新团队,发现一些同事对Git的常规操作没太大问题,但对Git的理解还是比较生疏,比如说分支和分支之间的关联关系、合并代码时候的冲突解决、提交代码前未拉取新代码导致冲突问题的处理等,我在协助处理这些问题的时候也记录各种问题的解决办法,希望整理后通过教程帮助到更多对Git操作进阶的开发者。 本期教程学习方法分为“掌握基础——稳步进阶——熟悉协作”三个层次。从掌握基础的 Git的推送和拉取开始,以案例进行演示,分析每一个步骤的操作方式和原理,从理解Git 工具的操作到学会代码存储结构、演示不同场景下Git遇到问题的不同处理方案。循序渐进让同学们掌握Git工具在团队协作中的整体协作流程。 在教程中会通过大量案例进行分析,案例会模拟在工作中遇到的问题,从最基础的代码提交和拉取、代码冲突解决、代码仓库的数据维护、Git服务端搭建等。为了让同学们容易理解,对Git简单易懂,文章中详细记录了详细的操作步骤,提供大量演示截图和解析。在教程的最后部分,会从提升团队整体效率的角度对Git工具进行讲解,包括规范操作、Gitlab的搭建、钩子事件的应用等。 为了让同学们可以利用碎片化时间来灵活学习,在教程文章中大程度降低了上下文的依赖,让大家可以在工作之余进行学习与实战,并同时掌握里面涉及的Git不常见操作的相关知识,理解Git工具在工作遇到的问题解决思路和方法,相信一定会对大家的前端技能进阶大有帮助。

实用主义学Python(小白也容易上手的Python实用案例)

原价169,限时立减100元! 系统掌握Python核心语法16点,轻松应对工作中80%以上的Python使用场景! 69元=72讲+源码+社群答疑+讲师社群分享会&nbsp; 【哪些人适合学习这门课程?】 1)大学生,平时只学习了Python理论,并未接触Python实战问题; 2)对Python实用技能掌握薄弱的人,自动化、爬虫、数据分析能让你快速提高工作效率; 3)想学习新技术,如:人工智能、机器学习、深度学习等,这门课程是你的必修课程; 4)想修炼更好的编程内功,优秀的工程师肯定不能只会一门语言,Python语言功能强大、使用高效、简单易学。 【超实用技能】 从零开始 自动生成工作周报 职场升级 豆瓣电影数据爬取 实用案例 奥运冠军数据分析 自动化办公:通过Python自动化分析Excel数据并自动操作Word文档,最终获得一份基于Excel表格的数据分析报告。 豆瓣电影爬虫:通过Python自动爬取豆瓣电影信息并将电影图片保存到本地。 奥运会数据分析实战 简介:通过Python分析120年间奥运会的数据,从不同角度入手分析,从而得出一些有趣的结论。 【超人气老师】 二两 中国人工智能协会高级会员 生成对抗神经网络研究者 《深入浅出生成对抗网络:原理剖析与TensorFlow实现》一书作者 阿里云大学云学院导师 前大型游戏公司后端工程师 【超丰富实用案例】 0)图片背景去除案例 1)自动生成工作周报案例 2)豆瓣电影数据爬取案例 3)奥运会数据分析案例 4)自动处理邮件案例 5)github信息爬取/更新提醒案例 6)B站百大UP信息爬取与分析案例 7)构建自己的论文网站案例

深度学习原理+项目实战+算法详解+主流框架(套餐)

深度学习系列课程从深度学习基础知识点开始讲解一步步进入神经网络的世界再到卷积和递归神经网络,详解各大经典网络架构。实战部分选择当下最火爆深度学习框架PyTorch与Tensorflow/Keras,全程实战演示框架核心使用与建模方法。项目实战部分选择计算机视觉与自然语言处理领域经典项目,从零开始详解算法原理,debug模式逐行代码解读。适合准备就业和转行的同学们加入学习! 建议按照下列课程顺序来进行学习 (1)掌握深度学习必备经典网络架构 (2)深度框架实战方法 (3)计算机视觉与自然语言处理项目实战。(按照课程排列顺序即可)

C/C++跨平台研发从基础到高阶实战系列套餐

一 专题从基础的C语言核心到c++ 和stl完成基础强化; 二 再到数据结构,设计模式完成专业计算机技能强化; 三 通过跨平台网络编程,linux编程,qt界面编程,mfc编程,windows编程,c++与lua联合编程来完成应用强化 四 最后通过基于ffmpeg的音视频播放器,直播推流,屏幕录像,

三个项目玩转深度学习(附1G源码)

从事大数据与人工智能开发与实践约十年,钱老师亲自见证了大数据行业的发展与人工智能的从冷到热。事实证明,计算机技术的发展,算力突破,海量数据,机器人技术等,开启了第四次工业革命的序章。深度学习图像分类一直是人工智能的经典任务,是智慧零售、安防、无人驾驶等机器视觉应用领域的核心技术之一,掌握图像分类技术是机器视觉学习的重中之重。针对现有线上学习的特点与实际需求,我们开发了人工智能案例实战系列课程。打造:以项目案例实践为驱动的课程学习方式,覆盖了智能零售,智慧交通等常见领域,通过基础学习、项目案例实践、社群答疑,三维立体的方式,打造最好的学习效果。

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

Python界面版学生管理系统

前不久上传了一个控制台版本的学生管理系统,这个是Python界面版学生管理系统,这个是使用pycharm开发的一个有界面的学生管理系统,基本的增删改查,里面又演示视频和完整代码,有需要的伙伴可以自行下

Vue.js 2.0之全家桶系列视频课程

基于新的Vue.js 2.3版本, 目前新全的Vue.js教学视频,让你少走弯路,直达技术前沿! 1. 包含Vue.js全家桶(vue.js、vue-router、axios、vuex、vue-cli、webpack、ElementUI等) 2. 采用笔记+代码案例的形式讲解,通俗易懂

linux“开发工具三剑客”速成攻略

工欲善其事,必先利其器。Vim+Git+Makefile是Linux环境下嵌入式开发常用的工具。本专题主要面向初次接触Linux的新手,熟练掌握工作中常用的工具,在以后的学习和工作中提高效率。

JAVA初级工程师面试36问(完结)

第三十一问: 说一下线程中sleep()和wait()区别? 1 . sleep()是让正在执行的线程主动让出CPU,当时间到了,在回到自己的线程让程序运行。但是它并没有释放同步资源锁只是让出。 2.wait()是让当前线程暂时退让出同步资源锁,让其他线程来获取到这个同步资源在调用notify()方法,才会让其解除wait状态,再次参与抢资源。 3. sleep()方法可以在任何地方使用,而wait()只能在同步方法或同步块使用。 ...

java jdk 8 帮助文档 中文 文档 chm 谷歌翻译

JDK1.8 API 中文谷歌翻译版 java帮助文档 JDK API java 帮助文档 谷歌翻译 JDK1.8 API 中文 谷歌翻译版 java帮助文档 Java最新帮助文档 本帮助文档是使用谷

我以为我对Mysql事务很熟,直到我遇到了阿里面试官

太惨了,面试又被吊打

智鼎(附答案).zip

并不是完整题库,但是有智鼎在线2019年9、10、11三个月的试题,有十七套以上题目,普通的网申行测题足以对付,可以在做题时自己总结一些规律,都不是很难

Visual Assist X 破解补丁

vs a's'sixt插件 支持vs2008-vs2019 亲测可以破解,希望可以帮助到大家

150讲轻松搞定Python网络爬虫

【为什么学爬虫?】 &nbsp; &nbsp; &nbsp; &nbsp;1、爬虫入手容易,但是深入较难,如何写出高效率的爬虫,如何写出灵活性高可扩展的爬虫都是一项技术活。另外在爬虫过程中,经常容易遇到被反爬虫,比如字体反爬、IP识别、验证码等,如何层层攻克难点拿到想要的数据,这门课程,你都能学到! &nbsp; &nbsp; &nbsp; &nbsp;2、如果是作为一个其他行业的开发者,比如app开发,web开发,学习爬虫能让你加强对技术的认知,能够开发出更加安全的软件和网站 【课程设计】 一个完整的爬虫程序,无论大小,总体来说可以分成三个步骤,分别是: 网络请求:模拟浏览器的行为从网上抓取数据。 数据解析:将请求下来的数据进行过滤,提取我们想要的数据。 数据存储:将提取到的数据存储到硬盘或者内存中。比如用mysql数据库或者redis等。 那么本课程也是按照这几个步骤循序渐进的进行讲解,带领学生完整的掌握每个步骤的技术。另外,因为爬虫的多样性,在爬取的过程中可能会发生被反爬、效率低下等。因此我们又增加了两个章节用来提高爬虫程序的灵活性,分别是: 爬虫进阶:包括IP代理,多线程爬虫,图形验证码识别、JS加密解密、动态网页爬虫、字体反爬识别等。 Scrapy和分布式爬虫:Scrapy框架、Scrapy-redis组件、分布式爬虫等。 通过爬虫进阶的知识点我们能应付大量的反爬网站,而Scrapy框架作为一个专业的爬虫框架,使用他可以快速提高我们编写爬虫程序的效率和速度。另外如果一台机器不能满足你的需求,我们可以用分布式爬虫让多台机器帮助你快速爬取数据。 &nbsp; 从基础爬虫到商业化应用爬虫,本套课程满足您的所有需求! 【课程服务】 专属付费社群+每周三讨论会+1v1答疑

JavaWEB商城项目(包括数据库)

功能描述:包括用户的登录注册,以及个人资料的修改.商品的分类展示,详情,加入购物车,生成订单,到银行支付等!另外还有收货地址的和我的收藏等常用操作.环境(JDK 1.7 ,mysql 5.5,Ecli

Python数据挖掘简易入门

&nbsp; &nbsp; &nbsp; &nbsp; 本课程为Python数据挖掘方向的入门课程,课程主要以真实数据为基础,详细介绍数据挖掘入门的流程和使用Python实现pandas与numpy在数据挖掘方向的运用,并深入学习如何运用scikit-learn调用常用的数据挖掘算法解决数据挖掘问题,为进一步深入学习数据挖掘打下扎实的基础。

一学即懂的计算机视觉(第一季)

图像处理和计算机视觉的课程大家已经看过很多,但总有“听不透”,“用不了”的感觉。课程致力于创建人人都能听的懂的计算机视觉,通过生动、细腻的讲解配合实战演练,让学生真正学懂、用会。 【超实用课程内容】 课程内容分为三篇,包括视觉系统构成,图像处理基础,特征提取与描述,运动跟踪,位姿估计,三维重构等内容。课程理论与实战结合,注重教学内容的可视化和工程实践,为人工智能视觉研发及算法工程师等相关高薪职位就业打下坚实基础。 【课程如何观看?】 PC端:https://edu.csdn.net/course/detail/26281 移动端:CSDN 学院APP(注意不是CSDN APP哦) 本课程为录播课,课程2年有效观看时长,但是大家可以抓紧时间学习后一起讨论哦~ 【学员专享增值服务】 源码开放 课件、课程案例代码完全开放给你,你可以根据所学知识,自行修改、优化 下载方式:电脑登录https://edu.csdn.net/course/detail/26281,点击右下方课程资料、代码、课件等打包下载

软件测试2小时入门

本课程内容系统、全面、简洁、通俗易懂,通过2个多小时的介绍,让大家对软件测试有个系统的理解和认识,具备基本的软件测试理论基础。 主要内容分为5个部分: 1 软件测试概述,了解测试是什么、测试的对象、原则、流程、方法、模型;&nbsp; 2.常用的黑盒测试用例设计方法及示例演示;&nbsp; 3 常用白盒测试用例设计方法及示例演示;&nbsp; 4.自动化测试优缺点、使用范围及示例‘;&nbsp; 5.测试经验谈。

初级玩转Linux+Ubuntu(嵌入式开发基础课程)

课程主要面向嵌入式Linux初学者、工程师、学生 主要从一下几方面进行讲解: 1.linux学习路线、基本命令、高级命令 2.shell、vi及vim入门讲解 3.软件安装下载、NFS、Samba、FTP等服务器配置及使用

2019 Python开发者日-培训

本次活动将秉承“只讲技术,拒绝空谈”的理念,邀请十余位身处一线的Python技术专家,重点围绕Web开发、自动化运维、数据分析、人工智能等技术模块,分享真实生产环境中使用Python应对IT挑战的真知灼见。此外,针对不同层次的开发者,大会还安排了深度培训实操环节,为开发者们带来更多深度实战的机会。

快速入门Android开发 视频 教程 android studio

这是一门快速入门Android开发课程,顾名思义是让大家能快速入门Android开发。 学完能让你学会如下知识点: Android的发展历程 搭建Java开发环境 搭建Android开发环境 Android Studio基础使用方法 Android Studio创建项目 项目运行到模拟器 项目运行到真实手机 Android中常用控件 排查开发中的错误 Android中请求网络 常用Android开发命令 快速入门Gradle构建系统 项目实战:看美图 常用Android Studio使用技巧 项目签名打包 如何上架市场

机器学习初学者必会的案例精讲

通过六个实际的编码项目,带领同学入门人工智能。这些项目涉及机器学习(回归,分类,聚类),深度学习(神经网络),底层数学算法,Weka数据挖掘,利用Git开源项目实战等。

4小时玩转微信小程序——基础入门与微信支付实战

这是一个门针对零基础学员学习微信小程序开发的视频教学课程。课程采用腾讯官方文档作为教程的唯一技术资料来源。杜绝网络上质量良莠不齐的资料给学员学习带来的障碍。 视频课程按照开发工具的下载、安装、使用、程序结构、视图层、逻辑层、微信小程序等几个部分组织课程,详细讲解整个小程序的开发过程

相关热词 c#中如何设置提交按钮 c#帮助怎么用 c# 读取合并单元格的值 c#带阻程序 c# 替换span内容 c# rpc c#控制台点阵字输出 c#do while循环 c#调用dll多线程 c#找出两个集合不同的
立即提问