java socket传输问题,等待接收 5C

在做数据传输的时候。服务端用OutputStream发送,客户端用BufferedInputStream接收,
这个时候不会阻塞。但是服务端用BufferedOutPutStream发送的时候,客户端会一直阻塞接收。
小弟菜鸟一枚,求大神解答。

4个回答

可能没有将BufferedInputStream刷新,注意将相关流的关闭

这有一个缓冲区的问题 应该是你没有刷新并且清空缓冲导致的

BufferedOutPutStream有缓存,每次write后调用一下flush方法

BufferedOutPutStream这个数据流的类实现就是批量写入数据的意思,如果只是调用write,这个时候数据是不会发送出去的,给人的感觉阻塞了,只有超过了缓存设置的上限,数据才会发送过去,可以尝试调用write之后,再次调用下flush()方法就可以了。

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
通过java socket传输XML
请问,在不同电脑间传输XML,如果A电脑接收了B电脑发送的XML,用dom4j解析XML得到有用数据后再如何动态生成XML,然后发送给C电脑? 好比B电脑要发送的XML只有几个空需要从A电脑的XML中读取数据填入,再发送给C电脑,这里数据自动补充填入采取什么方法? 刚学习这块没多久,希望好心人能够帮忙指点一下,理清思路,谢谢
java socket传输中用到split差分用户名密码
为什么我的代码不能支持多次登录,每登陆一次就要将服务器端代码再运行一次 // 客户端 传送账号密码 PrintWriter pw = new PrintWriter(new OutputStreamWriter((s.getOutputStream())),true); pw.println(user+"%"+pass); //客户端 返回服务端验证结果 BufferedReader br = new BufferedReader( new InputStreamReader(s.getinputstream())); String yorn = br.readLine(); if(yorn.equals("1")){ this.setVisible(false); new QQMain();//密码账号正确 进如QQ主页面 }else{ JOptionPane.showMessageDialog(this, "对不起,用户名或密码错误"); } //服务端 接收用户名和密码 BufferedReader br = new BufferedReader( new InputStreamReader(s.getinputstream())); String uandp = br.readLine(); String u =""; String p =""; try{ u = uandp.split("%")[0];//取账号 p = uandp.split("%")[1];//取密码 }catch(Exception e){} PrintWriter pw = new PrintWriter(new OutputStreamWriter((s.getOutputStream())),true); if(u.equals("liangyu")&&p.equals("521")){ //如果账号密码正确发送正确信息到客户端 pw.println("1"); }else{ //发送错误信息到客户端 pw.println("0"); } 附上错误 java.net.ConnectException: Connection refused: connect at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333) at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) at java.net.Socket.connect(Socket.java:519) at java.net.Socket.connect(Socket.java:469) at java.net.Socket.<init>(Socket.java:366) at java.net.Socket.<init>(Socket.java:180) at 客户端界面.QQLogin.actionPerformed(QQLogin.java:81) at javax.swing.AbstractButton.fireActionPerformed(AbstractButton.java:1995) at javax.swing.AbstractButton$Handler.actionPerformed(AbstractButton.java:2318) at javax.swing.DefaultButtonModel.fireActionPerformed(DefaultButtonModel.java:387) at javax.swing.DefaultButtonModel.setPressed(DefaultButtonModel.java:242) at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(BasicButtonListener.java:236) at java.awt.Component.processMouseEvent(Component.java:6216) at javax.swing.JComponent.processMouseEvent(JComponent.java:3265) at java.awt.Component.processEvent(Component.java:5981) at java.awt.Container.processEvent(Container.java:2041) at java.awt.Component.dispatchEventImpl(Component.java:4583) at java.awt.Container.dispatchEventImpl(Container.java:2099) at java.awt.Component.dispatchEvent(Component.java:4413) at java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4556) at java.awt.LightweightDispatcher.processMouseEvent(Container.java:4220) at java.awt.LightweightDispatcher.dispatchEvent(Container.java:4150) at java.awt.Container.dispatchEventImpl(Container.java:2085) at java.awt.Window.dispatchEventImpl(Window.java:2475) at java.awt.Component.dispatchEvent(Component.java:4413) at java.awt.EventQueue.dispatchEvent(EventQueue.java:599) at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:269) at java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:184) at java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:174) at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:169) at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:161) at java.awt.EventDispatchThread.run(EventDispatchThread.java:122) java.net.ConnectException: Connection refused: connect at java.net.PlainSocketImpl.socketConnect(Native Method) at java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333) at java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366) at java.net.Socket.connect(Socket.java:519) at java.net.Socket.connect(Socket.java:469) at java.net.Socket.<init>(Socket.java:366) at java.net.Socket.<init>(Socket.java:180) at 客户端界面.QQLogin.actionPerformed(QQLogin.java:81) at javax.swing.AbstractButton.fireActionPerformed(AbstractButton.java:1995) at javax.swing.AbstractButton$Handler.actionPerformed(AbstractButton.java:2318) at javax.swing.DefaultButtonModel.fireActionPerformed(DefaultButtonModel.java:387) at javax.swing.DefaultButtonModel.setPressed(DefaultButtonModel.java:242) at javax.swing.plaf.basic.BasicButtonListener.mouseReleased(BasicButtonListener.java:236) at java.awt.Component.processMouseEvent(Component.java:6216) at javax.swing.JComponent.processMouseEvent(JComponent.java:3265) at java.awt.Component.processEvent(Component.java:5981) at java.awt.Container.processEvent(Container.java:2041) at java.awt.Component.dispatchEventImpl(Component.java:4583) at java.awt.Container.dispatchEventImpl(Container.java:2099) at java.awt.Component.dispatchEvent(Component.java:4413) at java.awt.LightweightDispatcher.retargetMouseEvent(Container.java:4556) at java.awt.LightweightDispatcher.processMouseEvent(Container.java:4220) at java.awt.LightweightDispatcher.dispatchEvent(Container.java:4150) at java.awt.Container.dispatchEventImpl(Container.java:2085) at java.awt.Window.dispatchEventImpl(Window.java:2475) at java.awt.Component.dispatchEvent(Component.java:4413) at java.awt.EventQueue.dispatchEvent(EventQueue.java:599) at java.awt.EventDispatchThread.pumpOneEventForFilters(EventDispatchThread.java:269) at java.awt.EventDispatchThread.pumpEventsForFilter(EventDispatchThread.java:184) at java.awt.EventDispatchThread.pumpEventsForHierarchy(EventDispatchThread.java:174) at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:169) at java.awt.EventDispatchThread.pumpEvents(EventDispatchThread.java:161) at java.awt.EventDispatchThread.run(EventDispatchThread.java:122)
java socket 在外网和内网传输问题
今天写了一个java Socket的客户端和服务器端程序,在局域网环境中,客户端和服务端能够互相发送数据. 后来想把服务端的ip用Nat123映射出去,用客户端连接服务端映射出来的域名和端口结果服务端能接收客户端的数据,但客户端接收不了服务端的数据,本人百思不得其解,想请高手帮忙解答,本人感激不尽.
java socket 在内网和外网传输问题
今天写了一个java Socket的客户端和服务器端程序,在局域网环境中,客户端和服务端能够互相发送数据. 后来想把服务端的ip用Nat123映射出去,用客户端连接服务端映射出来的域名和端口结果服务端能接收客户端的数据,但客户端接收不了服务端的数据,本人百思不得其解,想请高手帮忙解答,本人感激不尽
java socket 网络传输文件使网络使用率最大化
局域网传输文件,如何使网络使用率最大化,主要问题是在客户端接收数据写入磁盘时会影响传输效率,有没有好的办法解决呢?
socket怎么传输java类
我现在是能实现socket传送类里面的某个属性,但是传送类的时候就卡住了,我的需求是就像传送类的某个属性一样把整个类从服务器传送过去,然后客户端接收,不知道是我的服务器传送问题还是客户端接收问题,求大神指点 java类 ``` public class Signer{ private String numb; private String room; private String time; private String io; }//需要传输的类 ``` 服务器发送 ``` PrintStream out = new PrintStream(client.getOutputStream()); out.println(person);//person是实例化类的对象 ``` 客户端接收 ``` buf=new BufferReader(new InputStreamReader(client.getInoutStream(),"gb2312")); while((Readline=buf.readLine())!=null){ System.out.println(Readline); } ```
关于java与c的socket通信问题
服务器端是java,客户端是c,通过socket,tcp通信,客户端将一张图片传输到服务器,服务器接收完成后返回一个‘ok’字符串作为应答。运行的时候,服务器可以接收到客户端发来的图片,但是客户端无法接收到服务器的‘ok’应答。对socket了解不深,求大神指点,谢谢了~代码如下: server(java): import java.net.*; import java.io.*; public class ServerTcp { public static void main(String args[])throws Exception{ ServerSocket server = new ServerSocket(8866); byte[] inputByte = null; int length = 0; DataInputStream dis = null; FileOutputStream fos = null; PrintStream out = null; fos = new FileOutputStream(new File("/home/gsw/test/cc.jpg")); inputByte = new byte[5120]; System.out.println("等待链接..."); Socket client = server.accept(); dis = new DataInputStream(client.getInputStream()); out = new PrintStream(client.getOutputStream()); while ((length = dis.read(inputByte, 0, inputByte.length)) > 0) { System.out.println(length); fos.write(inputByte, 0, length); fos.flush(); } System.out.println("完成接收"); out.print("ok"); //服务器应答 dis.close(); out.close(); fos.close(); client.close(); server.close(); System.out.println("关闭!"); } } client(c): #include <stdio.h> #include <sys/socket.h> #include <stdlib.h> #include <sys/types.h> #include <string.h> #include <unistd.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #define SER_PORT 8866 #define MAX_LEN 256 int main(int argc,char **argv) { int sd,rn; struct sockaddr_in client,server; char send_buf[MAX_LEN]; char recv_buf[MAX_LEN]; FILE *fq; int len,opt = 1; if( ( sd = socket(AF_INET,SOCK_STREAM,0)) == -1 ) { perror("socket"); exit(1); } bzero(&server,sizeof(server)); server.sin_family = AF_INET; server.sin_port = htons(SER_PORT); server.sin_addr.s_addr = inet_addr("127.0.0.1"); setsockopt(sd,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt)); if( connect(sd,(struct sockaddr *)&server,sizeof(server)) < 0 ) { perror("Connect"); close(sd); exit(1); } if( ( fq = fopen("1.jpg","rb") ) == NULL ) { perror("File open"); close(sd); exit(1); } bzero(send_buf,sizeof(send_buf)); memset(send_buf, 0, MAX_LEN); while( !feof(fq) ) { len = fread(send_buf,1,MAX_LEN,fq); if( len != write(sd,send_buf,len) ) { perror("write"); break; } } memset(recv_buf, 0, MAX_LEN); printf("send all!\n"); if(read(sd,recv_buf,sizeof(recv_buf)) ==-1) //接收应答 { perror("read"); exit(1); } printf("received from server:%s\n",recv_buf); close(sd); fclose(fq); return 0; } 程序也不报错,被阻塞了 server端控制台 ![图片说明](https://img-ask.csdn.net/upload/201504/27/1430099983_23487.png) client端 ![图片说明](https://img-ask.csdn.net/upload/201504/27/1430100004_345600.png)
MediaRecorder录屏,Socket传输录屏内容报错java.lang.IllegalStateException
用模拟器调试可以运行,用真机测试在 mediaRecorder.prepare();抛异常 ``` package www.xjw.com.mymiracast2.screenrecordservice; import android.app.Notification; import android.app.Service; import android.content.Context; import android.content.Intent; import android.hardware.display.DisplayManager; import android.hardware.display.VirtualDisplay; import android.media.MediaRecorder; import android.media.projection.MediaProjection; import android.media.projection.MediaProjectionManager; import android.os.IBinder; import android.os.ParcelFileDescriptor; import java.net.Socket; /** * Created by dzjin on 2018/1/9. */ public class ScreenRecordService extends Service { private int resultCode; private Intent resultData=null; private MediaProjection mediaProjection=null; private MediaRecorder mediaRecorder=null; private VirtualDisplay virtualDisplay=null; private int mScreenWidth; private int mScreenHeight; private int mScreenDensity; private static String filePathName; private Socket receiver = null; private ParcelFileDescriptor pfd = null; private Context context=null; private String host = null; private int port = 8989; @Override public void onCreate() { super.onCreate(); //startForeground(2, new Notification()); } /** * 每次客户端通过调用startService(Intent)显式启动服务时,系统调用startService(Intent), *提供它提供的参数和表示启动请求的唯一整数标记。 * 不要直接调用这个方法。 * @param intent * @param flags * @param startId * @return */ @Override public int onStartCommand(Intent intent, int flags, int startId) { try{ resultCode=intent.getIntExtra("resultCode",-1); resultData=intent.getParcelableExtra("resultData"); mScreenWidth=intent.getIntExtra("mScreenWidth",0); mScreenHeight=intent.getIntExtra("mScreenHeight",0); mScreenDensity=intent.getIntExtra("mScreenDensity",0); filePathName=intent.getStringExtra("filePathName"); host=intent.getStringExtra("host"); port=intent.getIntExtra("port",8989); receiver = new Socket(host, port); pfd = ParcelFileDescriptor .fromSocket(receiver); mediaProjection=createMediaProjection(); mediaRecorder=createMediaRecorder(); virtualDisplay=createVirtualDisplay(); mediaRecorder.start(); }catch (Exception e) { e.printStackTrace(); } /** * START_NOT_STICKY: *从onStartCommand返回的常量(Intent, int, int):如果这个服务的进程是 *在启动时被杀死(从onStartCommand(Intent, int, int)返回后), *没有新的start意图交付给它,然后将服务从 *启动状态,在以后显式调用Context.startService(Intent)之前不要重新创建。 *服务将不会接收带有空意图的onStartCommand(Intent, int, int)调用 *因为如果没有等待交付的意图,它将不会重新启动。 */ return Service.START_NOT_STICKY; } public MediaProjection createMediaProjection(){ /** *使用getSystemService(类)检索MediaProjectionManager实例 *管理媒体放映会议。 */ return ((MediaProjectionManager)getSystemService(Context.MEDIA_PROJECTION_SERVICE)) .getMediaProjection(resultCode,resultData); /** *检索从成功的屏幕捕获请求中获得的MediaProjection。 *如果startActivityForResult()的结果不是RESULT_OK,则*将为null。 */ } private MediaRecorder createMediaRecorder(){ //用于录制音频和视频。录音控制是基于一个简单的状态机。 MediaRecorder mediaRecorder=new MediaRecorder(); //设置要录音的源。 //mediaRecorder.setAudioSource(MediaRecorder. AudioSource.CAMCORDER); //设置要录制的视频源。 mediaRecorder.setVideoSource(MediaRecorder.VideoSource.SURFACE); //设置录制过程中产生的输出的格式。 //3GPP媒体文件格式 mediaRecorder.setOutputFormat(MediaRecorder.OutputFormat.MPEG_2_TS); //设置录音格式 //mediaRecorder.setAudioEncoder(MediaRecorder.AudioEncoder.AMR_NB); //设置录像编码比特率。 //param:以比特/秒为单位的视频编码比特率 mediaRecorder.setVideoEncodingBitRate(5*mScreenWidth*mScreenHeight); //设置录像编码器用于录像。 mediaRecorder.setVideoEncoder(MediaRecorder.VideoEncoder.H264); //设置要拍摄的视频的宽度和高度。 mediaRecorder.setVideoSize(mScreenWidth,mScreenHeight); //设置要捕获视频的帧速率。 mediaRecorder.setVideoFrameRate(60); try{ mediaRecorder.setOutputFile(pfd.getFileDescriptor()); //mediaRecorder.setOutputFile(filePathName); **此次抛异常** //准备记录器开始捕捉和编码数据。 mediaRecorder.prepare(); }catch (Exception e){ e.printStackTrace(); } return mediaRecorder; } private VirtualDisplay createVirtualDisplay(){ /** *名称字符串:虚拟显示的名称,必须是非空的。这个值不能为空。 width int:虚拟显示的宽度,以像素为单位。必须大于0。 高度int:虚拟显示器的高度,以像素为单位。必须大于0。 dpi int: dpi中虚拟显示的密度。必须大于0。 标志int:虚拟显示标志的组合。有关标志的完整列表,请参见DisplayManager。 surface surface:虚拟显示内容应该呈现到的表面,如果一开始没有,则为null。 回调virtualdisplay。回调:当虚拟显示的状态改变时调用的回调,如果没有,则为空。 处理程序处理程序:应该在其上调用回调的处理程序,如果应该在调用线程的主循环程序上调用回调,则为null。 */ /** * DisplayManager.VIRTUAL_DISPLAY_FLAG_AUTO_MIRROR *虚拟显示标志:当没有显示内容时,允许在私有显示上镜像内容。 */ return mediaProjection.createVirtualDisplay("mediaProjection",mScreenWidth,mScreenHeight,mScreenDensity, DisplayManager.VIRTUAL_DISPLAY_FLAG_AUTO_MIRROR,mediaRecorder.getSurface(),null,null); } @Override public void onDestroy() { super.onDestroy(); if(virtualDisplay!=null){ virtualDisplay.release(); virtualDisplay=null; } if(mediaRecorder!=null){ mediaRecorder.stop(); mediaRecorder=null; } if(mediaProjection!=null){ mediaProjection.stop(); mediaProjection=null; } } @Override public IBinder onBind(Intent intent) { System.out.println("==============================="); return null; } } ``` I/MediaRecorder: enter in file frameworks/av/media/libmedia/mediarecorder.cpp, function prepare, line 461 I/IMediaRecorder: prepare (BpMediaRecorder client) in file frameworks/av/media/libmedia/IMediaRecorder.cpp, function prepare, line 249 W/com.mymiracast2: type=1400 audit(0.0:104572): avc: denied { read write } for path="socket:[8870267]" dev="sockfs" ino=8870267 scontext=u:r:mediaserver:s0 tcontext=u:r:untrusted_app:s0:c512,c768 tclass=tcp_socket permissive=0 E/MediaRecorder: prepare failed: -38 W/zygote64: Got a deoptimization request on un-deoptimizable method void android.media.MediaRecorder._prepare() W/System.err: java.lang.IllegalStateException W/System.err: at android.media.MediaRecorder._prepare(Native Method) W/System.err: at android.media.MediaRecorder.prepare(MediaRecorder.java:1017) W/System.err: at www.xjw.com.mymiracast2.screenrecordservice.ScreenRecordService.createMediaRecorder(ScreenRecordService.java:137) W/System.err: at www.xjw.com.mymiracast2.screenrecordservice.ScreenRecordService.onStartCommand(ScreenRecordService.java:79) W/System.err: at android.app.ActivityThread.handleServiceArgs(ActivityThread.java:4151) W/System.err: at android.app.ActivityThread.-wrap21(Unknown Source:0) W/System.err: at android.app.ActivityThread$H.handleMessage(ActivityThread.java:2119) W/System.err: at android.os.Handler.dispatchMessage(Handler.java:108) W/System.err: at android.os.Looper.loop(Looper.java:166) W/System.err: at android.app.ActivityThread.main(ActivityThread.java:7529) W/System.err: at java.lang.reflect.Method.invoke(Native Method) W/System.err: at com.android.internal.os.Zygote$MethodAndArgsCaller.run(Zygote.java:245) W/System.err: at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:921) E/MediaRecorder: SurfaceMediaSource could not be initialized! W/System.err: java.lang.IllegalStateException: failed to get surface at android.media.MediaRecorder.getSurface(Native Method) W/System.err: at www.xjw.com.mymiracast2.screenrecordservice.ScreenRecordService.createVirtualDisplay(ScreenRecordService.java:160) at www.xjw.com.mymiracast2.screenrecordservice.ScreenRecordService.onStartCommand(ScreenRecordService.java:80) W/System.err: at android.app.ActivityThread.handleServiceArgs(ActivityThread.java:4151) at android.app.ActivityThread.-wrap21(Unknown Source:0) at android.app.ActivityThread$H.handleMessage(ActivityThread.java:2119) at android.os.Handler.dispatchMessage(Handler.java:108) W/System.err: at android.os.Looper.loop(Looper.java:166) at android.app.ActivityThread.main(ActivityThread.java:7529) at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.Zygote$MethodAndArgsCaller.run(Zygote.java:245) W/System.err: at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:921) D/StrictMode: StrictMode policy violation; ~duration=7334 ms: android.os.StrictMode$StrictModeNetworkViolation: policy=65543 violation=4 at android.os.StrictMode$AndroidBlockGuardPolicy.onNetwork(StrictMode.java:1466) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:356) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:201) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:183) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:356) at java.net.Socket.connect(Socket.java:616) at java.net.Socket.connect(Socket.java:565) at java.net.Socket.<init>(Socket.java:445) at java.net.Socket.<init>(Socket.java:217) at www.xjw.com.mymiracast2.screenrecordservice.ScreenRecordService.onStartCommand(ScreenRecordService.java:74) at android.app.ActivityThread.handleServiceArgs(ActivityThread.java:4151) at android.app.ActivityThread.-wrap21(Unknown Source:0) at android.app.ActivityThread$H.handleMessage(ActivityThread.java:2119) at android.os.Handler.dispatchMessage(Handler.java:108) at android.os.Looper.loop(Looper.java:166) at android.app.ActivityThread.main(ActivityThread.java:7529) at java.lang.reflect.Method.invoke(Native Method) at com.android.internal.os.Zygote$MethodAndArgsCaller.run(Zygote.java:245) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:921) D/StrictMode: StrictMode policy violation; ~duration=7332 ms: android.os.StrictMode$StrictModeNetworkViolation: policy=65543 violation=4 ``` ```
【java】Socket连接成功但是无法传输数据
socket连接上服务端但是无法传输数据。 为此写了个测试的服务端、一个纯代码客户端、一个窗口客户端。 这是服务端测试代码,只是展开连接接收数据的: ``` public class 客户端聊天测试 { public static void main(String[] args) throws Exception{ ServerSocket server = new ServerSocket(10032); Socket socket = server.accept(); InputStream in = socket.getInputStream(); BufferedReader br = new BufferedReader(new InputStreamReader(in)); String str = ""; System.out.println("服务器模拟端已展开在10032端口"); while(!str.equals("exit!")) { str = br.readLine(); System.out.println(str); } br.close(); in.close(); socket.close(); server.close(); } } ``` 下面是一个简单的连接客户端,只是发送数据的: ``` public class 消息发送测试 { public static void main(String[] args) throws Exception{ // TODO 自动生成的方法存根 Socket socket = new Socket("localhost", 10032); OutputStream out = socket.getOutputStream(); BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(out)); bw.write("hello world\n"); bw.write("你好"); bw.newLine(); bw.write("exit!"); bw.close(); out.close(); socket.close(); } } ``` 附上运行结果: ![运行结果](https://img-ask.csdn.net/upload/201901/23/1548185610_352385.png) 到此完全没有问题,BUT: 我试着做成窗体模式发送数据时却只能连接上服务端而不能发送数据过去,下面是界面 ![图片说明](https://img-ask.csdn.net/upload/201901/23/1548186703_736328.png) 界面代码省略,我在界面的构造方法里添加了下面的代码(注:socket\out\bw均已经声明为成员变量): ``` try { socket = new Socket("localhost", 10032); out = socket.getOutputStream(); bw = new BufferedWriter(new OutputStreamWriter(out)); bw.write("hellow"); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } ``` 其按钮监视器的代码如下: ``` class jian implements ActionListener{ public void actionPerformed(ActionEvent e) { try { bw.write(txt.getText()); bw.newLine(); System.out.println(txt.getText()); txt.setText(""); } catch (IOException e1) { // TODO 自动生成的 catch 块 e1.printStackTrace(); } } } ``` 逻辑来说应该没问题然而这运行结果就很惨淡: ![运行结果](https://img-ask.csdn.net/upload/201901/23/1548186319_330372.png) 无论怎么输入都不能接受到消息,在监视器里的那句println是输出来了,但是服务端根本没接收到数据,但是连接确实是建立起来了,求大神帮忙ing
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地址的问题。那我就彻底费解了。 还请各位好心的有经验的朋友们帮我参考一下,到底如何解决这个问题,谢谢大家 因为现在已经没有路由器所以应该不用端口转发,之前用路由器的时候也试过端口转发,是不行的,后来直接把路由器撤了。
java 中用多线程实现 UDP 传输的问题
我用多线程实现了发送数据和接收数据的 UDP 传输 但是结果很奇怪,第一次键盘输入后传输过来的数据是正常的 但往后的数据传输结果就开始变得很奇怪,总是莫名其妙多出很多字母![图片说明](https://img-ask.csdn.net/upload/201909/10/1568129293_920283.png) 但是我是跟着视频写的代码,我把视频里的代码复制过来也是这么回事,是不是 java 版本的问题??我的java是最新版的 以下是代码部分,请各位大神不吝赐教,谢谢! ``` public class Demo5_Thread { public static void main(String[] args) { new Receive().start(); new Socket().start(); } } //发送方 class Socket extends Thread { public void run() { try { Scanner sc = new Scanner(System.in); DatagramSocket socket = new DatagramSocket(); while (true) { String line = sc.nextLine(); if ("quit".equals(line)) { break; } DatagramPacket packet = new DatagramPacket(line.getBytes(), line.getBytes().length, InetAddress.getByName("10.24.3.58"), 666); socket.send(packet); } socket.close(); } catch (IOException e) { e.printStackTrace(); } } } //接收方 class Receive extends Thread{ public void run() { try { DatagramSocket socket = new DatagramSocket(666); DatagramPacket packet = new DatagramPacket(new byte[1024], 1024); while (true) { socket.receive(packet); String ip = packet.getAddress().getHostAddress(); int port = packet.getPort(); byte[] arr = packet.getData(); int len = packet.getLength(); System.out.println(ip + ":" + port + ":" + new String(arr, 0, len)); } } catch (IOException e) { e.printStackTrace(); } } } ```
java 关于用socket发送soap报文的问题
最近做个项目 用socket实现soap协议传输, 我这里做了个socket服务端,接收客户端发送的soap请求经过处理后返回响应soap报文, 结果对方收到我的响应报文,有时候出现报文不完整的问题,有时候接收到前半部分,有时候是后半部分,有时候是完整的, 我想问下这种情况是应用问题还是网络问题,客户端的代码我不能修改的是别的厂商做的,我问他们怎么判断接收了 一条完整的报文,他们回答是根据报文头和报文尾来判断的, 我是用apache——mina框架来做socket服务端的 。
使用socket通信,android客户端,java写的服务器,传输数据时总出现异常
客户端: public void run() { // TODO Auto-generated method stub try { s = new Socket(ip, port); DataOutputStream os = new DataOutputStream(s.getOutputStream()); os.writeUTF("可以准备接收了吗?"); ObjectOutputStream out = new ObjectOutputStream(s.getOutputStream()); out.writeObject(u); out.flush(); out.close(); System.out.println("用户名是:"+u.getID()); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } ``` ``` 服务器: ``` try{ ServerSocket ss = new ServerSocket(9999); System.out.println("服务器正在监听!"); Socket s = ss.accept(); System.out.println("建立连接!"); DataInputStream is = new DataInputStream(s.getInputStream()); String str = is.readUTF(); System.out.println(str); ObjectInputStream ois = new ObjectInputStream(s.getInputStream()); User u = (User)ois.readObject(); ois.close(); System.out.println("用户ID :"+u.getID()); }catch(Exception e){ e.printStackTrace(); } ``` 异常: java.net.SocketException: Connection reset at java.net.SocketInputStream.read(Unknown Source) at java.net.SocketInputStream.read(Unknown Source) at java.net.SocketInputStream.read(Unknown Source) at java.io.DataInputStream.readUnsignedShort(Unknown Source) at java.io.DataInputStream.readUTF(Unknown Source) at java.io.DataInputStream.readUTF(Unknown Source) at com.server.EasyServer.main(EasyServer.java:24) (在os.writeUTF一行)
实现两个Java项目通讯传输XML
请问,如果两个Java项目在不同的IDE,比如一个在Myeclipse,一个在Netbeans,Myeclipse程序要向Netbeans传输XML,请问如何实现Netbeans接收并显示XML的程序?通讯要用Socket吗?Netbeans这部分代码并没有写 初学不久还不太懂,希望好心人能指点一下方向,多谢
关于Socket的问题
最近在做一个用java Socket编程实现CHAP协议的一个作业,我写的代码分为服务器端和客户端!服务器端启动后就进入监听连接状态:[code="java"]while(true) { try { Socket socket = chapServer.getServerSocket().accept(); System.out.println("与" + socket.getInetAddress().toString().substring(1) + "链路建立成功"); ServerThread thread = (ServerThread) XMLConfigReader.getInstance().getThreadBean("serverThread"); thread.init(socket, chapServer.getName()); thread.startNewChallenge(); Date timeStart = new Date(); while(true) { System.out.println("main线程"); if((new Date().getTime() - timeStart.getTime()) % TIMEINTERVAL == 0) { System.out.println("-----------再次挑战-----------------"); thread.startNewChallenge(); } } } catch (IOException e) { e.printStackTrace(); } }[/code] 当客户端连接上服务器端后,服务器端和客户端就各自马上启动自己的线程,此时客户端就处于监听输入流的状态即代码执行到[code="java"]receive = dis.readUTF();[/code],服务器这时马上向客户端发送一个挑战报文(挑战报文发送后,服务器端也进入到监听输入流的状态,等待客户端的相应报文),客户端接收到挑战报文后就像服务器端发送响应报文,然后服务器端接收到客户端的相应报文后,就验证客户端是否挑战成功,如果成功与否都向客户端发送响应的报文。我现在的问题是当服务器端发送挑战报文后,如果在传输的过程中报文丢失,那么客户端和服务器端此时都处于监听输入流状态,这时两边岂不都僵持在等待输入流的状态?那这个问题怎么解决?求解答,其实我这个是仿照写聊天室写的,是不是俺的思考方向错了?
自己写了一个关于java UDP传输文件的代码,运行不了,没有错误,不知道哪里出问题了,求助!
发送端: import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.io.BufferedInputStream; import java.io.DataInputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.Inet4Address; import java.net.SocketException; import java.util.Date; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JPanel; import javax.swing.JTextField; public class LoginJiemian { public static void main(String[] args) throws FileNotFoundException { new FileSend().FileSen(); } } class FileSend{ JFrame jFrame; JPanel InputPanel; JLabel PortNumberLabel; JButton buttonChooseFile,buttonTransportFile; JTextField textPortNumber; File file; byte[] buffer,bufferPacketNum,bufferPacketContent,receiveByte; DatagramPacket packet,packet1; DatagramSocket socket; DataInputStream fis; int read; long a; int Num; String str; FileSend() throws FileNotFoundException{ try { socket = new DatagramSocket(9); String filePath = "e:\\mysql.rar"; fis = new DataInputStream(new BufferedInputStream( new FileInputStream(filePath))); } catch (SocketException e) { e.printStackTrace(); } FileSen(); } public void FileSen(){ jFrame = new JFrame("UDP文件传输"); jFrame.setBounds(400, 200,400, 400); jFrame.setLayout(null); jFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); InputPanel=new JPanel(); InputPanel.setBounds(0,0,400, 400); InputPanel.setLayout(null); //两个功能按钮 buttonChooseFile=new JButton("选择文件"); buttonChooseFile.setBounds(20, 10, 100, 28); buttonTransportFile=new JButton("发送"); buttonTransportFile.setBounds(20, 50, 100, 28); //文本输入框 输入端口号 textPortNumber=new JTextField(); textPortNumber.setBounds(200, 10, 130, 20); //标签 提示输入端口号 PortNumberLabel=new JLabel("端口号"); PortNumberLabel.setBounds(200, 50, 130, 20); InputPanel.add(buttonChooseFile); InputPanel.add(buttonTransportFile); InputPanel.add(textPortNumber); InputPanel.add(PortNumberLabel); jFrame.add(InputPanel); jFrame.setVisible(true); buttonChooseFile.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { } }); buttonTransportFile.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { try { receiveByte = new byte[20]; bufferPacketNum=new byte[20]; bufferPacketContent=new byte[1024]; buffer=new byte[1080]; Num=1; a = new Date().getTime(); read = 0; if (fis != null) { try { read = fis.read(bufferPacketContent); buffer=byteMerger(intToByteArray(Num),bufferPacketContent); packet = new DatagramPacket(buffer,0,buffer.length, (Inet4Address) Inet4Address.getByName("localhost"), 8); packet1=packet;//备份重传 socket.send(packet); } catch (IOException e1) { e1.printStackTrace(); } } if (read == -1) { System.out.print("用时:"); System.out.println(new Date().getTime() - a); return; } while (true) { packet = new DatagramPacket(receiveByte, receiveByte.length); socket.receive(packet); if (fis != null) { str = new String(packet.getData(),0,packet.getLength()); System.out.println(str); if(str.equals(new String().valueOf(Num))){ Num++; read = fis.read(bufferPacketContent); buffer=byteMerger(intToByteArray(Num),bufferPacketContent); packet = new DatagramPacket(buffer,buffer.length, (Inet4Address) Inet4Address.getByName("localhost"), 8); packet1=packet;//备份重传 socket.send(packet); }else{ socket.send(packet1); } } if (read == -1) { System.out.print("用时:"); System.out.println(new Date().getTime() - a); break; } } } catch (FileNotFoundException e1) { e1.printStackTrace(); } catch (SocketException e1) { e1.printStackTrace(); } catch (IOException e1) { e1.printStackTrace(); } } }); } public static byte[] intToByteArray(int i) { byte[] result = new byte[4]; //由高位到低位 result[0] = (byte)((i >> 24) & 0xFF); result[1] = (byte)((i >> 16) & 0xFF); result[2] = (byte)((i >> 8) & 0xFF); result[3] = (byte)(i & 0xFF); return result; } public static byte[] byteMerger(byte[] byte_1, byte[] byte_2){ byte[] byte_3 = new byte[byte_1.length+byte_2.length]; System.arraycopy(byte_1, 0, byte_3, 0, byte_1.length); System.arraycopy(byte_2, 0, byte_3, byte_1.length, byte_2.length); return byte_3; } } 接收端: import java.io.BufferedOutputStream; import java.io.DataOutputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.Inet4Address; import java.net.SocketException; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JLabel; import javax.swing.JPanel; import javax.swing.JTextField; public class UdpReceive { public static void main(String[] args) throws IOException { new FileRece().Udprecev();; } } class FileRece{ JFrame jFrame; JPanel InputPanel; JLabel PortNumberLabel; JButton buttonSaveFile; JTextField textPortNumber; DatagramSocket dataSocket; final int PORT = 8; byte[] receiveByte,receiveByte1,sendByte; DatagramPacket dataPacket; String FileName,str; DataOutputStream fileOut; int j,len; public FileRece() throws SocketException, FileNotFoundException { dataSocket = new DatagramSocket(PORT); fileOut = new DataOutputStream( new BufferedOutputStream(new FileOutputStream( "D:\\mysql.rar"))); receiveByte = new byte[1080]; sendByte=new byte[20]; } public void Udprecev() throws IOException{ j=0; while(true){ dataPacket = new DatagramPacket(receiveByte, receiveByte.length); dataSocket.receive(dataPacket); String s=""+j; //把数字转成字符串 len=s.length(); str = new String(dataPacket.getData(),0,len); System.out.println(str); if(str.equals(new String().valueOf(j+1))){ // 指定接收到数据的长度,可使接收数据正常显示,开始时很容易忽略这一点 fileOut.write(receiveByte, len, dataPacket.getLength()); fileOut.flush(); j++; sendByte=intToByteArray(j); dataPacket = new DatagramPacket(sendByte,sendByte.length, (Inet4Address) Inet4Address.getByName("localhost"), 9); dataSocket.send(dataPacket); } } } public static byte[] intToByteArray(int i) { byte[] result = new byte[4]; //由高位到低位 result[0] = (byte)((i >> 24) & 0xFF); result[1] = (byte)((i >> 16) & 0xFF); result[2] = (byte)((i >> 8) & 0xFF); result[3] = (byte)(i & 0xFF); return result; } }
java 关于NIO实现UDP数据传输问题 ,急谢谢,C币不足请不要介意
各位大侠好,小弟想问一下问题,搞了一两天没有搞明白的。因为要实现一个UDP传输服务端,于是在网上找了很多资料然后就写了一个。但是写好之后发现有两个很严重的问题,希望各位大哥给点意见或者思路去解决。 问题一:启动服务端,同时也启动客户端,客户端传输数据服务器正常接收,但是断开客户端后,再启动客户端,服务器就收不到任何客户端发送的消息,好像是服务器关闭了UDP一样,但是重启服务器后(重新打开UDP)客户端既可以发送信息过来。 问题二:多个客户端。第一个客户端连接上后,第二个客户端怎么也链接不上了。即使关闭了第一个客户端也一样。 如下是代码: package com.gateway.socket; import java.io.IOException; import java.net.InetSocketAddress; import java.net.SocketAddress; import java.net.UnknownHostException; import java.nio.ByteBuffer; import java.nio.channels.DatagramChannel; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.util.Iterator; import java.util.Set; import org.apache.log4j.Logger; public class UDPEchoServerSelector extends Thread { private static final Logger log = Logger.getLogger(ServerSocket.class); // private InetSocketAddress inetSocketAddress; // socket处理类 private UDPSocketHandler handler = new UDPSocketHandler(); // 注册的接受服务 private SocketReceiver receiver = null; /** * 初始化socket * * @param receiver * @param hostname * @param port * @throws IOException * @throws UnknownHostException */ public UDPEchoServerSelector(SocketReceiver receiver, String hostname, int port) { if (hostname.isEmpty()) { inetSocketAddress = new InetSocketAddress(port); } else { inetSocketAddress = new InetSocketAddress(hostname, port); } this.receiver = receiver; } @Override public void run() { try { Selector selector = Selector.open(); // 创建选择器,可以处理多路通道。 DatagramChannel serverSocketChannel = DatagramChannel.open(); // 打开通道 serverSocketChannel.configureBlocking(false); // 非阻塞 serverSocketChannel.socket().bind(inetSocketAddress); /* * 将通道管理器和该通道绑定,并为该通道注册SelectionKey.OP_READ事件,注册该事件后, * 当该事件到达时,selector.select()会返回,如果该事件没到达selector.select()会一直阻塞。 */ serverSocketChannel.register(selector, SelectionKey.OP_READ, new ClientData()); log.info("Server: socket server started."); /* * 采用轮询的方式监听selector上是否有需要处理的事件,如果有,则进行处理 */ while (true) { // 轮询 // 当注册的事件到达时,方法返回;否则,该方法会一直阻塞 int nKeys = selector.select(); if (nKeys == 0) { continue; } // 得到选择键列表 Set Keys = selector.selectedKeys(); Iterator it = Keys.iterator(); while (it.hasNext()) { SelectionKey key = null; key = (SelectionKey) it.next(); // 键为位掩码 it.remove(); // 客户端请求连接事件 if (key.isValid() && key.isWritable()) { log.info("Server: SelectionKey is acceptable."); handler.handleWrite(key); } if (key.isReadable()) {// 获得了可读的事件 log.info("Server: SelectionKey is readable."); handler.receiveMsg(key, receiver); } } Keys.clear(); } } catch (IOException e) { e.printStackTrace(); } } public static class ClientData { public SocketAddress clientAddress; public ByteBuffer buffer = ByteBuffer.allocate(255); } } package com.gateway.socket; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.DatagramChannel; import java.nio.channels.SelectionKey; import org.apache.log4j.Logger; import com.gateway.common.DeviceDataTools; import com.gateway.common.data.HexUtils; import com.gateway.socket.UDPEchoServerSelector.ClientData; /** * * 处理socket类 * * @author Andy * */ public class UDPSocketHandler { private static Logger log = Logger.getLogger(UDPSocketHandler.class); /** * 链接请求 * * @throws IOException */ public void handleWrite(SelectionKey key) { try { DatagramChannel channel = (DatagramChannel) key.channel(); ClientData clntDat = (ClientData) key.attachment(); clntDat.buffer.flip(); // 从起始位置开始发送 int bytesSent; bytesSent = channel.send(clntDat.buffer, clntDat.clientAddress); if (bytesSent != 0) { key.interestOps(SelectionKey.OP_READ); // 关注客户端发送数据 } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * 读请求 * * @throws IOException */ public void receiveMsg(SelectionKey key, SocketReceiver receiver) { ByteBuffer byteBuffer = ByteBuffer.allocate(1024); byteBuffer.clear(); DatagramChannel socketChannel = (DatagramChannel) key.channel(); //非阻塞 try { socketChannel.configureBlocking(false); } catch (IOException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } System.out.println("channel code:" + socketChannel.hashCode()); try { while (true) { InetSocketAddress client = (InetSocketAddress) socketChannel .receive(byteBuffer); byteBuffer.flip(); // byteBuffer中传过来的是10进制的bytep[] byte[] dst = new byte[byteBuffer.limit()]; byteBuffer.get(dst); // 将10进制的byte[]转化成16进制字符串 String data = HexUtils.converBytesToHex(dst); System.out.println(data); log.info("Server: data1 = " + data); byteBuffer.clear(); receiver.udpreceive(socketChannel, data, client); break; } } catch (java.io.IOException e) { //e.printStackTrace(); //this.closeChannel(key, socketChannel); } catch (Exception e) { //e.printStackTrace(); //this.closeChannel(key, socketChannel); } } /** * * @param socketChannel */ private void closeChannel(SelectionKey key, DatagramChannel socketChannel) { try { while (socketChannel.isOpen()) { key.cancel(); socketChannel.close(); } } catch (IOException e1) { e1.printStackTrace(); } } /** * 根据socketKey从内存中获取channel,通过channel向client端发送消息 * * @param socketKey * 内存在channel对应的key * @param data * 发送的数据 * @return * @throws IOException */ public static boolean send(String socketKey, String data) throws IOException { DatagramChannel socketChannel = SocketChannelMapper .getUDPChannel(socketKey); if (socketChannel == null || !socketChannel.isOpen()) { return false; } InetSocketAddress client = SocketChannelMapper .getUDPInetSocketAddress(socketKey + "address"); boolean f = socketChannel.isConnected(); ByteBuffer byteBuffer = ByteBuffer.wrap(DeviceDataTools.hex2Byte(data)); if (f) { socketChannel.write(byteBuffer); } else { socketChannel.connect(new InetSocketAddress(client.getAddress(), client.getPort())); socketChannel.send(byteBuffer, client); } return true; } /** * 根据socketKey从内存中获取channel,通过channel向client端发送消息 * * @param socketKey * 内存在channel对应的key * @param data * 发送的数据 * @return * @throws IOException */ public static boolean send(DatagramChannel socketChannel, String data, InetSocketAddress client) throws IOException { if (socketChannel == null) { return false; } System.out.println("#########################ADDRESS" + client.getAddress()); System.out.println("#########################PORT" + client.getPort()); boolean f = socketChannel.isConnected(); ByteBuffer byteBuffer = ByteBuffer.wrap(DeviceDataTools.hexStr2ByteArray(data)); if (f) { socketChannel.write(byteBuffer); } else { socketChannel.connect(new InetSocketAddress(client.getAddress(), client.getPort())); socketChannel.send(byteBuffer, client); } return true; } }
socket编程write和read方式对应
1.NumberConverter.java public interface NumberConverter { public int toInt(byte[] b,int x,int y); } 2.MyServer.java import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; public class MyServer { private int lengthOffset; private int lengthSize; private int lengthAddtive; public int getLengthOffset() { return lengthOffset; } public void setLengthOffset(int lengthOffset) { this.lengthOffset = lengthOffset; } public int getLengthSize() { return lengthSize; } public void setLengthSize(int lengthSize) { this.lengthSize = lengthSize; } public int getLengthAddtive() { return lengthAddtive; } public void setLengthAddtive(int lengthAddtive) { this.lengthAddtive = lengthAddtive; } public void setNumberConverter(NumberConverter numberConverter){ this.numberConverter = numberConverter; } private NumberConverter numberConverter = new NumberConverter(){ public int toInt(byte[] b, int i, int i_0_) { String temp = ""; int i_1_ = 0; for(int i_2_=0;i_2_<i_0_;i_2_++){ temp = Byte.toString(b[i+i_2_]); if(!("32").equals(temp)){ i_1_ = i_1_*10 + ((b[i+i_2_] & 0xff) - 48); } } return i_1_; } }; public byte[] getBytesByLength(InputStream in0,int off,int len,NumberConverter converter,int addtive) throws IOException{ DataInputStream in1 = new DataInputStream(in0); byte[] lengthBytes = new byte[off+len]; in1.readFully(lengthBytes); int length = converter.toInt(lengthBytes, off, len); length+=addtive; System.out.println("接收客户端传输的字符长度为:"+length); return lengthBytes; } private byte[] resolve(InputStream in) throws IOException { lengthOffset = 0; lengthSize = 7; if(lengthSize>0){ return (getBytesByLength(in, lengthOffset, lengthSize, numberConverter, lengthAddtive)); }else{ throw new IllegalArgumentException("length size must > 0"); } } public static void main(String[] args) throws IOException { ServerSocket server = new ServerSocket(9999); System.out.println("我是服务器,等待客户端连接..."); Socket ssoc = null; String sendStr = "你好,我是服务器。"; while(true){ ssoc = server.accept(); //测试--重要步骤,关键 MyServer ms = new MyServer(); ms.resolve(ssoc.getInputStream()); //读取客户端的请求信息 InputStream in = ssoc.getInputStream(); DataInputStream din = new DataInputStream(in); String receiveStr = null; byte[] rBuf = new byte[7]; din.read(rBuf); receiveStr = new String(rBuf,0,7); System.out.println("我是服务器,客户端请求的信息:"+receiveStr); //响应客户端的请求 OutputStream out = ssoc.getOutputStream(); DataOutputStream dout = new DataOutputStream(out); byte[] buf = sendStr.getBytes(); out.write(buf); //关闭资源 out.close(); in.close(); ssoc.close(); } } } 3.MyClient.java import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.net.Socket; public class MyClient { public static void main(String[] args) throws IOException{ Socket soc = new Socket("127.0.0.1",9999); System.out.println("我是客户端,连接中..."); String sendStr = "<ap></ap>"; //向服务器发送消息 OutputStream out = soc.getOutputStream(); DataOutputStream dout = new DataOutputStream(out); byte[] buf = sendStr.getBytes(); out.write(buf); //读取服务器响应消息 InputStream in = soc.getInputStream(); DataInputStream din = new DataInputStream(in); String receiveStr = null; byte[] rBuf = new byte[1024]; din.read(rBuf); receiveStr = new String(rBuf); System.out.println("我是客户端,服务器响应的信息:"+receiveStr); //关闭资源 in.close(); out.close(); soc.close(); } } 疑问:System.out.println("接收客户端传输的字符长度为:"+length);接收客户端传输的字符长度为:17555239; 怎样通过修改MyClient.java,让此长度正确读取后转换为正确的字符串长度。 MyServer中resolve方法相关都不可以变更。因为这部分是框架中的内容,包括toInt方法都不可变。 请教一下,大神。万分感谢!
Java多线程服务器问题,executorservice的用法
创建了一个Java多线程服务器,通过socket连接不断接收大量设备(客户端)传输过来的信息 ``` // 创建可以容纳4个线程的线程池 ExecutorService fixedThreadPool = Executors.newFixedThreadPool(4); ``` 当连接数达到4个时出现了阻塞状态,求解怎么解决,怎么在完成一次数据解析后释放工作线程接收下一个连接,有点卡壳
在中国程序员是青春饭吗?
今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...
《MySQL 性能优化》之理解 MySQL 体系结构
本文介绍 MySQL 的体系结构,包括物理结构、逻辑结构以及插件式存储引擎。
程序员请照顾好自己,周末病魔差点一套带走我。
程序员在一个周末的时间,得了重病,差点当场去世,还好及时挽救回来了。
复习一周,京东+百度一面,不小心都拿了Offer
京东和百度一面都问了啥,面试官百般刁难,可惜我全会。
Java 14 都快来了,为什么还有这么多人固守Java 8?
从Java 9开始,Java版本的发布就让人眼花缭乱了。每隔6个月,都会冒出一个新版本出来,Java 10 , Java 11, Java 12, Java 13, 到2020年3月份,...
达摩院十大科技趋势发布:2020 非同小可!
【CSDN编者按】1月2日,阿里巴巴发布《达摩院2020十大科技趋势》,十大科技趋势分别是:人工智能从感知智能向认知智能演进;计算存储一体化突破AI算力瓶颈;工业互联网的超融合;机器间大规模协作成为可能;模块化降低芯片设计门槛;规模化生产级区块链应用将走入大众;量子计算进入攻坚期;新材料推动半导体器件革新;保护数据隐私的AI技术将加速落地;云成为IT技术创新的中心 。 新的画卷,正在徐徐展开。...
轻松搭建基于 SpringBoot + Vue 的 Web 商城应用
首先介绍下在本文出现的几个比较重要的概念: 函数计算(Function Compute): 函数计算是一个事件驱动的服务,通过函数计算,用户无需管理服务器等运行情况,只需编写代码并上传。函数计算准备计算资源,并以弹性伸缩的方式运行用户代码,而用户只需根据实际代码运行所消耗的资源进行付费。Fun: Fun 是一个用于支持 Serverless 应用部署的工具,能帮助您便捷地管理函数计算、API ...
讲真,这两个IDE插件,可以让你写出质量杠杠的代码
周末躺在床上看《拯救大兵瑞恩》 周末在闲逛的时候,发现了两个优秀的 IDE 插件,据说可以提高代码的质量,我就安装了一下,试了试以后发现,确实很不错,就推荐给大家。 01、Alibaba Java 代码规范插件 《阿里巴巴 Java 开发手册》,相信大家都不会感到陌生,其 IDEA 插件的下载次数据说达到了 80 万次,我今天又贡献了一次。嘿嘿。 该项目的插件地址: https://github....
Python+OpenCV实时图像处理
目录 1、导入库文件 2、设计GUI 3、调用摄像头 4、实时图像处理 4.1、阈值二值化 4.2、边缘检测 4.3、轮廓检测 4.4、高斯滤波 4.5、色彩转换 4.6、调节对比度 5、退出系统 初学OpenCV图像处理的小伙伴肯定对什么高斯函数、滤波处理、阈值二值化等特性非常头疼,这里给各位分享一个小项目,可通过摄像头实时动态查看各类图像处理的特点,也可对各位调参、测试...
2020年一线城市程序员工资大调查
人才需求 一线城市共发布岗位38115个,招聘120827人。 其中 beijing 22805 guangzhou 25081 shanghai 39614 shenzhen 33327 工资分布 2020年中国一线城市程序员的平均工资为16285元,工资中位数为14583元,其中95%的人的工资位于5000到20000元之间。 和往年数据比较: yea...
为什么猝死的都是程序员,基本上不见产品经理猝死呢?
相信大家时不时听到程序员猝死的消息,但是基本上听不到产品经理猝死的消息,这是为什么呢? 我们先百度搜一下:程序员猝死,出现将近700多万条搜索结果: 搜索一下:产品经理猝死,只有400万条的搜索结果,从搜索结果数量上来看,程序员猝死的搜索结果就比产品经理猝死的搜索结果高了一倍,而且从下图可以看到,首页里面的五条搜索结果,其实只有两条才是符合条件。 所以程序员猝死的概率真的比产品经理大,并不是错...
害怕面试被问HashMap?这一篇就搞定了!
声明:本文以jdk1.8为主! 搞定HashMap 作为一个Java从业者,面试的时候肯定会被问到过HashMap,因为对于HashMap来说,可以说是Java集合中的精髓了,如果你觉得自己对它掌握的还不够好,我想今天这篇文章会非常适合你,至少,看了今天这篇文章,以后不怕面试被问HashMap了 其实在我学习HashMap的过程中,我个人觉得HashMap还是挺复杂的,如果真的想把它搞得明明白...
毕业5年,我问遍了身边的大佬,总结了他们的学习方法
我问了身边10个大佬,总结了他们的学习方法,原来成功都是有迹可循的。
python爬取百部电影数据,我分析出了一个残酷的真相
2019年就这么匆匆过去了,就在前几天国家电影局发布了2019年中国电影市场数据,数据显示去年总票房为642.66亿元,同比增长5.4%;国产电影总票房411.75亿元,同比增长8.65%,市场占比 64.07%;城市院线观影人次17.27亿,同比增长0.64%。 看上去似乎是一片大好对不对?不过作为一名严谨求实的数据分析师,我从官方数据中看出了一点端倪:国产票房增幅都已经高达8.65%了,为什...
推荐10个堪称神器的学习网站
每天都会收到很多读者的私信,问我:“二哥,有什么推荐的学习网站吗?最近很浮躁,手头的一些网站都看烦了,想看看二哥这里有什么新鲜货。” 今天一早做了个恶梦,梦到被老板辞退了。虽然说在我们公司,只有我辞退老板的份,没有老板辞退我这一说,但是还是被吓得 4 点多都起来了。(主要是因为我掌握着公司所有的核心源码,哈哈哈) 既然 4 点多起来,就得好好利用起来。于是我就挑选了 10 个堪称神器的学习网站,推...
这些软件太强了,Windows必装!尤其程序员!
Windows可谓是大多数人的生产力工具,集娱乐办公于一体,虽然在程序员这个群体中都说苹果是信仰,但是大部分不都是从Windows过来的,而且现在依然有很多的程序员用Windows。 所以,今天我就把我私藏的Windows必装的软件分享给大家,如果有一个你没有用过甚至没有听过,那你就赚了????,这可都是提升你幸福感的高效率生产力工具哦! 走起!???? NO、1 ScreenToGif 屏幕,摄像头和白板...
阿里面试,面试官没想到一个ArrayList,我都能跟他扯半小时
我是真的没想到,面试官会这样问我ArrayList。
曾经优秀的人,怎么就突然不优秀了。
职场上有很多辛酸事,很多合伙人出局的故事,很多技术骨干被裁员的故事。说来模板都类似,曾经是名校毕业,曾经是优秀员工,曾经被领导表扬,曾经业绩突出,然而突然有一天,因为种种原因,被裁员了,...
大学四年因为知道了这32个网站,我成了别人眼中的大神!
依稀记得,毕业那天,我们导员发给我毕业证的时候对我说“你可是咱们系的风云人物啊”,哎呀,别提当时多开心啦????,嗯,我们导员是所有导员中最帅的一个,真的???? 不过,导员说的是实话,很多人都叫我大神的,为啥,因为我知道这32个网站啊,你说强不强????,这次是绝对的干货,看好啦,走起来! PS:每个网站都是学计算机混互联网必须知道的,真的牛杯,我就不过多介绍了,大家自行探索,觉得没用的,尽管留言吐槽吧???? 社...
良心推荐,我珍藏的一些Chrome插件
上次搬家的时候,发了一个朋友圈,附带的照片中不小心暴露了自己的 Chrome 浏览器插件之多,于是就有小伙伴评论说分享一下我觉得还不错的浏览器插件。 我下面就把我日常工作和学习中经常用到的一些 Chrome 浏览器插件分享给大家,随便一个都能提高你的“生活品质”和工作效率。 Markdown Here Markdown Here 可以让你更愉快的写邮件,由于支持 Markdown 直接转电子邮...
看完这篇HTTP,跟面试官扯皮就没问题了
我是一名程序员,我的主要编程语言是 Java,我更是一名 Web 开发人员,所以我必须要了解 HTTP,所以本篇文章就来带你从 HTTP 入门到进阶,看完让你有一种恍然大悟、醍醐灌顶的感觉。 最初在有网络之前,我们的电脑都是单机的,单机系统是孤立的,我还记得 05 年前那会儿家里有个电脑,想打电脑游戏还得两个人在一个电脑上玩儿,及其不方便。我就想为什么家里人不让上网,我的同学 xxx 家里有网,每...
2020 年,大火的 Python 和 JavaScript 是否会被取而代之?
Python 和 JavaScript 是目前最火的两大编程语言,但是2020 年,什么编程语言将会取而代之呢? 作者 |Richard Kenneth Eng 译者 |明明如月,责编 | 郭芮 出品 | CSDN(ID:CSDNnews) 以下为译文: Python 和 JavaScript 是目前最火的两大编程语言。然而,他们不可能永远屹立不倒。最终,必将像其他编程语言一...
史上最全的IDEA快捷键总结
现在Idea成了主流开发工具,这篇博客对其使用的快捷键做了总结,希望对大家的开发工作有所帮助。
阿里程序员写了一个新手都写不出的低级bug,被骂惨了。
这种新手都不会范的错,居然被一个工作好几年的小伙子写出来,差点被当场开除了。
谁是华为扫地僧?
是的,华为也有扫地僧!2020年2月11-12日,“养在深闺人不知”的华为2012实验室扫地僧们,将在华为开发者大会2020(Cloud)上,和大家见面。到时,你可以和扫地僧们,吃一个洋...
Idea 中最常用的10款插件(提高开发效率),一定要学会使用!
学习使用一些插件,可以提高开发效率。对于我们开发人员很有帮助。这篇博客介绍了开发中使用的插件。
AI 没让人类失业,搞 AI 的人先失业了
最近和几个 AI 领域的大佬闲聊 根据他们讲的消息和段子 改编出下面这个故事 如有雷同 都是巧合 1. 老王创业失败,被限制高消费 “这里写我跑路的消息实在太夸张了。” 王葱葱哼笑一下,把消息分享给群里。 阿杰也看了消息,笑了笑。在座几位也都笑了。 王葱葱是个有名的人物,21岁那年以全额奖学金进入 KMU 攻读人工智能博士,累计发表论文 40 余篇,个人技术博客更是成为深度学习领域内风向标。 ...
2020年,冯唐49岁:我给20、30岁IT职场年轻人的建议
点击“技术领导力”关注∆每天早上8:30推送 作者|Mr.K 编辑| Emma 来源|技术领导力(ID:jishulingdaoli) 前天的推文《冯唐:职场人35岁以后,方法论比经验重要》,收到了不少读者的反馈,觉得挺受启发。其实,冯唐写了不少关于职场方面的文章,都挺不错的。可惜大家只记住了“春风十里不如你”、“如何避免成为油腻腻的中年人”等不那么正经的文章。 本文整理了冯...
作为一名大学生,如何在B站上快乐的学习?
B站是个宝,谁用谁知道???? 作为一名大学生,你必须掌握的一项能力就是自学能力,很多看起来很牛X的人,你可以了解下,人家私底下一定是花大量的时间自学的,你可能会说,我也想学习啊,可是嘞,该学习啥嘞,不怕告诉你,互联网时代,最不缺的就是学习资源,最宝贵的是啥? 你可能会说是时间,不,不是时间,而是你的注意力,懂了吧! 那么,你说学习资源多,我咋不知道,那今天我就告诉你一个你必须知道的学习的地方,人称...
那些年,我们信了课本里的那些鬼话
教材永远都是有错误的,从小学到大学,我们不断的学习了很多错误知识。 斑羚飞渡 在我们学习的很多小学课文里,有很多是错误文章,或者说是假课文。像《斑羚飞渡》: 随着镰刀头羊的那声吼叫,整个斑羚群迅速分成两拨,老年斑羚为一拨,年轻斑羚为一拨。 就在这时,我看见,从那拨老斑羚里走出一只公斑羚来。公斑羚朝那拨年轻斑羚示意性地咩了一声,一只半大的斑羚应声走了出来。一老一少走到伤心崖,后退了几步,突...
立即提问