java 客户端Socket端口问题

tcp问题,客户端Socket提问,getLocalPort(),连接的是本地的服务端,第一次运行是2880,第二次运行是2881,第三次运行是2882,我想了解客户端的端口是怎么回事,端口是怎么分配的?

4个回答

一个连接占用一个端口,分配端口有自己的算法
像这个就是随机分配不常用的

端口分配没有什么规定,像偶在程序实现 TCP/UDP 的程序中都是随便选一个不常用的端口。
客户端使用什么端口,一般由服务器决定。因为只有尝试连接服务器的指定端口,才能与服务器建立连接。

TCP 服务端启动时需要自己绑定端口,而客户端启动时不需自己绑定端口,会随机分配一个不常用的端口。

在TCP/IP的端口分配机制中看到,服务器的保留端口是用来监听发送到服务器的请求的。
当服务器收到客户端请求后,便会建立一个线程负责跟客户端进行通信,而这个新建的线程的端口号是服务器自由分配的,即客户端Socket的端口,这样建立通信之后,然后这个线程继续用这个端口与客户机通信的。
相同问题的帖子:http://bbs.csdn.net/topics/390278142

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
在socket中,如何让客户端固定它的端口

我想在socket通信中,让server能判断clinet连上来的是谁。 通常我们写socket通信时,server都这这样写的java: ``` ServerSocket server = new ServerSocket(9090); socket = server.accept(); ``` c++ qt中: ``` tcpserver = new QTcpServer(); tcpserver->listen(QHostAddress::Any,9090); connect(tcpserver,SIGNAL(newConnection()),this,SLOT(connected())); ``` 客户端java和c++都是差不多的。 可是当客户端链接到server时,同一个客户端每次链接所用的端口都是不同的。如何让client链接到server的端口固定下来,不要每次都随机。 我打算用这个实现判断客户端是谁。或者有没有其他更好的办法。

java socket怎么获取端口心跳包数据?

1、返回400 ``` public static synchronized String tcpPost(String clientIp,String clientPort,String msg){ String rs = ""; if(clientIp==null||"".equals(clientIp)||clientPort==null||"".equals(clientPort)){ logger.error("Ip或端口不存在..."); return null; } int clientPortInt = Integer.parseInt(clientPort); logger.info("clientIp:"+clientIp+" clientPort:"+clientPort); Socket s = null; OutputStream out = null; InputStream in = null; try { s = new Socket(clientIp, clientPortInt); s.setSendBufferSize(4096); s.setTcpNoDelay(true); s.setSoTimeout(60*1000); s.setKeepAlive(true); out = s.getOutputStream(); in = s.getInputStream(); //准备报文msg logger.info("准备发送报文:"+msg); out.write(msg.getBytes("GBK")); out.flush(); byte[] rsByte = readStream(in); if(rsByte!=null){ rs = new String(rsByte, "GBK"); } } catch (Exception e) { logger.error("tcpPost发送请求异常:"+e.getMessage()); }finally{ logger.info("tcpPost(rs):"+rs); ```

使用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服务器接收不到客户端发来的消息

package socket; public class MySeverSocket { public static void main(String[] args) { new ServerListener().start(); } } **************************************** package socket; import java.io.IOException; import java.net.ServerSocket; import java.net.Socket; import javax.swing.JOptionPane; public class ServerListener extends Thread { public void run (){ try { ServerSocket serverSocket = new ServerSocket(55555); while (true){ Socket socket = serverSocket.accept(); JOptionPane.showMessageDialog(null, "有客户端连接到了55555端口"); ChatSocket cs = new ChatSocket(socket); cs.start(); ChatManager.getChatManager().add(cs); } } catch (IOException e) { e.printStackTrace(); } } } *************************************** package socket; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.UnsupportedEncodingException; import java.net.Socket; public class ChatSocket extends Thread { Socket socket; public ChatSocket(Socket s) { this.socket = s; } public void out(String out) { try { socket.getOutputStream().write(out.getBytes("UTF-8")); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } @Override public void run() { try { BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8")); String line = null; while ((line = br.readLine()) != null) { ChatManager.getChatManager().publich(this, line); } br.close(); } catch (UnsupportedEncodingException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } ******************************************************** package socket; import java.util.Vector; public class ChatManager { private ChatManager() {} private static final ChatManager cm = new ChatManager(); public static ChatManager getChatManager() { return cm; } Vector<ChatSocket> vector = new Vector<ChatSocket>(); public void add(ChatSocket cs) { vector.add(cs); } public void publich(ChatSocket cs,String out) { for(int i = 0;i<vector.size();i++){ ChatSocket csChatSocket = vector.get(i); if (!cs.equals(csChatSocket)) { csChatSocket.out(out); } } } } 安卓客户端连接与发送消息方法 public void connect(){ final AsyncTask<Void,String,Void> read = new AsyncTask<Void, String, Void>() { String iptext = ip.getText().toString(); @Override protected Void doInBackground(Void... params) { try { socket = new Socket(iptext,55555); writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); publishProgress("@success"); } catch (IOException e) { Toast.makeText(MainActivity.this,"连接失败",Toast.LENGTH_SHORT).show(); e.printStackTrace(); } try { String line; while ((line = reader.readLine()) != null){ publishProgress(line); } } catch (IOException e) { e.printStackTrace(); } return null; } @Override protected void onProgressUpdate(String... values) { if (values[0].equals("@success")){ Toast.makeText(MainActivity.this,"连接成功",Toast.LENGTH_SHORT).show(); } text.append("别人说"+values[0]+"\n"); super.onProgressUpdate(values); } }; read.execute(); } public void send(){ try { // text.append("我说:"+editText.getText().toString()+"\n"); writer.write(editText.getText().toString()+"\n"); writer.flush(); editText.setText(""); } catch (IOException e) { e.printStackTrace(); } }

java socket 端口转发遇到的问题

下面的程序运行之后,没有办法通过8081端口连上数据库服务器,这是为什么呢 package mis.client; import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; import java.io.InterruptedIOException; import java.io.OutputStream; import java.net.ServerSocket; import java.net.Socket; import lcc.SysLog; public class Client { public static void main(String[] args) throws Exception { Socket toDb = new Socket("10.11.112.48", 1521); ServerSocket serverServer = new ServerSocket(8081); Socket toServer = serverServer.accept(); InputStream toDbInStream = toDb.getInputStream(); OutputStream toDbOutStream = toDb.getOutputStream(); InputStream toServerInStream = toServer.getInputStream(); OutputStream toServerOutStream = toServer.getOutputStream(); System.out.println("客户端初始化完成"); pipe(toDbInStream,toServerInStream,toServerOutStream,toDbOutStream); } private static void pipe(InputStream is0, InputStream is1, OutputStream os0,OutputStream os1) { try { int ir; byte bytes[] = new byte[1024]; System.out.println(0); while (true) { try { if ((ir = is0.read(bytes)) > 0) { System.out.println(1); os0.write(bytes, 0, ir); } else if (ir < 0) { break; } } catch (InterruptedIOException e) { System.out.println("error--1"); } try { if ((ir = is1.read(bytes)) > 0) { System.out.println(2); os1.write(bytes, 0, ir); } else if (ir < 0) { break; } } catch (InterruptedIOException e) { System.out.println("error--2"); } } } catch (Exception e0) { } } } 补充:我程序的意图是把目标服务器1521端口的的数据转发的本地8081端口上,然后我用plsql工具去连库,程序只负责转发数据,现在的情况是数据没有转发过来

java创建socket时失败的原因有哪些?

最近练习使用socket时,本来能够脸上服务器的,后来不知道怎么的就连不上了,最后定位就是socket创建失败,什么原因我不知道。我知道的原因如下: 1、没有添加连接网络权限。 2、没有在后台线程中创建socket 3、端口号被占用 这些问题我都避免了,而且之前就连上了,后来连不上,抛出IOException,请问还有其他的原因会导致socket创建失败吗?

java socket tcp 和网络映射问题

我用java socket 写了个客户端和服务端程序,局域网测试没有问题-客户端和服务器端能互发数据. 于是想用花生壳端口映射服务端, 然后用客户端连接发现如下问题 1.服务端能收到客户端的信息,但客户端不能收到服务端信息 ----说明网络没问题 2.我把服务端的接受代码删去让他只能发送, 把客户端的发送发送代码删去让他不能接受结果,客户端就能收到服务端的信息 ---但这又有什么用呢? ----说明网络没问题 3.我还怀疑是程序的问题,但在局域网内服务端和客户端能够互发信息 ----说明软件没问题 因此我就纳闷了---到底问题出在哪呢 ???

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

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

java的socket服务端程序传到Linux上编译运行成功,但是监听不到客户端的连接

(很急!!!没有财务值了,能帮我解决问题微信红包答谢!最好微信或者QQ交流 qq:543527507)我用了最简单的C/S程序TCP连接,在阿里云租了一个服务器,得到了一个公网IP,也把服务器socket与公网IP绑定,在自己电脑完全没问题,但是把它传到Linux远端服务器上运行,这个ServerSocket.accept()就监听不到我主机的客户端程序的连接,但是我主机的客户端能够连上公网IP的socket,但是服务器就监听不到?两个问题,第一,为什么我主机上能够连接但是服务器那边监听不到?第二,如果我主机连接的socket不是服务器的socket那我主机连接的是什么?

JAVA Socket获取主机名的问题

socket.getInetAddress().getHostName(); 这个语句为什么得到的是IP地址? 请问怎样获取客户端的主机名? 环境: RHEL 6.4 JAVA 1.6

java socket 通信 服务端接收的文件大于客户端发出的文件 是什么鬼

//服务端 package Socket; import java.io.BufferedInputStream; import java.io.BufferedReader; import java.io.DataInputStream; import java.io.File; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.Socket; public class Server2User extends Thread{ private Socket socket; private InputStream is; private BufferedInputStream bis; private FileOutputStream fos; private File file; private byte name[] = new byte[1024]; private byte transport[] = new byte[1024]; private File path; public Server2User(Socket socket) { this.socket= socket; } public void run() { try { is = socket.getInputStream(); bis= new BufferedInputStream(is); bis.read(name); String filename = new String(name); filename = filename.trim(); System.out.println("得到文件名"+filename); path = this.createFile(filename); System.out.println(path.getName()); int length; fos = new FileOutputStream(path); int i = 0; while((length=bis.read(transport))!=-1) { this.write2file(transport); i++; } this.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } private void write2file(byte[] transport) { try { fos.write(transport); } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } private File createFile(String filename) { try { file = new File("f:/test/"+filename); file.createNewFile(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return file; } private void close() { try { if(is!=null) is.close(); if(bis!=null) bis.close(); if(fos!=null) fos.close(); if(is!=null) is.close(); if(socket!=null) socket.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } //客户端 package Socket; import java.io.BufferedOutputStream; import java.io.BufferedReader; import java.io.File; import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.PrintWriter; import java.io.Reader; import java.net.Socket; import java.net.UnknownHostException; public class ClientSocket_upload { private Socket socket; private OutputStream os; private BufferedOutputStream bos; private String path; private FileInputStream fis; private File file; public ClientSocket_upload(String path) { this.path = path; } public void uploadfile(){ try { //1.创建客户端Socket,指定服务器地址和端口 socket= new Socket("10.104.77.108", 1080); //2.获取输出流,向服务器端发送信息 os = socket.getOutputStream();//字节输出流 bos = new BufferedOutputStream(os); file = new File(path); fis= new FileInputStream(file); String name = file.getName(); byte[] temp = name.getBytes(); byte[] bname = new byte[1024]; byte[] by = new byte[1024]; for(int i = 0 ;i<=bname.length-1;i++) { if(i<=temp.length-1) { bname[i] = temp[i]; } else { bname[i]=0; } } bos.write(bname); while((fis.read(by))!=-1) { bos.write(by); } fis.close(); bos.close(); os.close(); socket.close(); } catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }

Java 的 Socket服务端客户端以tcp/ip协议发送接收报文

代码谁有模板,比如给你一个login报文,logout报文!!急急急!!!

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();

端口映射后socket怎样建立连接

我想通过socket使两台电脑建立连接,两台电脑都处于不同的局域网中,所以要先端口映射。其中一台电脑通过端口映射后的ip地址为180.160.71.130:3389 . 在映射后怎样写socket的关键语句使得两台电脑建立连接呢? 在端口映射之前socket语句是这样的,并且两台电脑在同一个局域网下可以工作: //服务器 DWORD WINAPI AnswerThread(LPVOID lparam) { printf("Thread ID:%4d create!\n", GetCurrentThreadId()); int ret; char buf[50] = { 0 }; char sendBuf[80] = { 0 }; SOCKET clientSocket = (SOCKET)(LPVOID)lparam; while (true) { memset(buf, 0, sizeof(buf)); ret = recv(clientSocket, buf, sizeof(buf), 0); if (ret<=0) { break; } printf("revc: %s\n", buf); sprintf_s(sendBuf, "Thread ID:%4d revced", GetCurrentThreadId()); ret = send(clientSocket, sendBuf, strlen(sendBuf) + sizeof(char), 0); if (ret <= 0) { break; } } printf("Thread ID:%4d stop!\n", GetCurrentThreadId()); closesocket(clientSocket); return 1; } int _tmain(int argc, _TCHAR* argv[]) { WORD wVersionRequested; WSADATA wsaData; wVersionRequested = MAKEWORD(1, 1); if (WSAStartup(wVersionRequested, &wsaData) == INVALID_SOCKET) { return 0; } if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { WSACleanup(); return 0; } SOCKET sockSrv = socket(AF_INET, SOCK_STREAM, 0); int len = sizeof(SOCKADDR); SOCKADDR_IN clientAddr; SOCKADDR_IN serviceAddr; serviceAddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY); serviceAddr.sin_family = AF_INET; serviceAddr.sin_port = htons(8000); if (bind(sockSrv, (SOCKADDR*)&serviceAddr, len) == INVALID_SOCKET) { printf("failed bind!\n"); closesocket(sockSrv); WSACleanup(); return 0; } if (listen(sockSrv, LISTEN_MAX_COUNT) == SOCKET_ERROR) { printf("Listen failed with error: %ld\n", WSAGetLastError()); closesocket(sockSrv); WSACleanup(); return 0; } SOCKET sockClient; HANDLE hThread = NULL; DWORD dwThreadId; while (1) { sockClient = accept(sockSrv, (SOCKADDR*)&clientAddr, &len); Sleep(1000); hThread = CreateThread(NULL, NULL, AnswerThread, (LPVOID)sockClient, 0, &dwThreadId); if (hThread == NULL) { printf("CreatThread AnswerThread() failed.\n"); } } closesocket(sockSrv); WSACleanup(); return 0; } 客户端 client 代码: //客户端 int _tmain(int argc, _TCHAR* argv[]) { WORD wVersionRequested; WSADATA wsaData; int err; wVersionRequested = MAKEWORD(1, 1); if (WSAStartup(wVersionRequested, &wsaData) == INVALID_SOCKET) { return -1; } if (LOBYTE(wsaData.wVersion) != 1 || HIBYTE(wsaData.wVersion) != 1) { WSACleanup(); return -1; } SOCKET sockClient = socket(AF_INET, SOCK_STREAM, 0); int len = sizeof(SOCKADDR); SOCKADDR_IN local; local.sin_addr.S_un.S_addr = inet_addr("222.66.117.26"); local.sin_family = AF_INET; local.sin_port = htons(8000); if (connect(sockClient, (SOCKADDR*)&local, len) == INVALID_SOCKET) { printf("connect error/n"); return 0; } char inputBuf[30]; char recvBuf[50]; int ret; // while (scanf_s("%s", inputBuf, sizeof(inputBuf)) != EOF) while (gets_s(inputBuf)) { if (strcmp(inputBuf, "stop") ==0) { break; } ret = send(sockClient, inputBuf, strlen(inputBuf) + sizeof(char), 0); if (ret<=0) { printf("send failed!\n"); break; } ret = recv(sockClient, recvBuf, sizeof(recvBuf), 0); if (ret <= 0) { printf("recv failed!\n"); break; } printf("my reply is : %s\n", recvBuf); //printf("%s\n", inet_ntoa(local.sin_addr)); } closesocket(sockClient); WSACleanup(); return 0; }

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 实现socket的异步通信

我在网上也找到一个例子,但是没有客户端,我自己写了一个用ServerSocket连的客户端,但是连接上后不能写也不能读,不知道怎么回事,请高手解决。最好能给一个简单异步编程的例子。 下面是代码: package org.scorpion.scoket; /** * * @author chenjd */ import java.io.IOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.nio.channels.SelectableChannel; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.nio.charset.CharacterCodingException; import java.nio.charset.Charset; import java.nio.charset.CharsetDecoder; import java.util.HashMap; import java.util.Iterator; import java.util.Set; public class NBServer { int port = 8090; int BUFFERSIZE = 1024; Selector selector = null; ServerSocketChannel serverChannel = null; HashMap clientChannelMap = null;// 用来存放每一个客户连接对应的套接字和通道 public NBServer(int port) { this.clientChannelMap = new HashMap(); this.port = port; } public void initialize() throws IOException { // 初始化,分别实例化一个选择器,一个服务器端可选择通道 this.selector = Selector.open(); this.serverChannel = ServerSocketChannel.open(); this.serverChannel.configureBlocking(false); InetAddress localhost = InetAddress.getLocalHost(); InetSocketAddress isa = new InetSocketAddress(localhost, this.port); this.serverChannel.socket().bind(isa);// 将该套接字绑定到服务器某一可用端口 } // 结束时释放资源 public void finalize() throws IOException { this.serverChannel.close(); this.selector.close(); } // 将读入字节缓冲的信息解码 public String decode(ByteBuffer byteBuffer) throws CharacterCodingException { Charset charset = Charset.forName("ISO-8859-1"); CharsetDecoder decoder = charset.newDecoder(); CharBuffer charBuffer = decoder.decode(byteBuffer); String result = charBuffer.toString(); return result; } // 监听端口,当通道准备好时进行相应操作 public void portListening(String data) throws IOException, InterruptedException { // 服务器端通道注册OP_ACCEPT事件 SelectionKey acceptKey = this.serverChannel.register(this.selector, SelectionKey.OP_ACCEPT); // 当有已注册的事件发生时,select()返回值将大于0 while (acceptKey.selector().select() > 0) { System.out.println("event happened"); // 取得所有已经准备好的所有选择键 Set readyKeys = this.selector.selectedKeys(); // 使用迭代器对选择键进行轮询 Iterator i = readyKeys.iterator(); while (i.hasNext()) { SelectionKey key = (SelectionKey) i.next(); i.remove();// 删除当前将要处理的选择键 if (key.isAcceptable()) {// 如果是有客户端连接请求 System.out.println("more client connect in!"); ServerSocketChannel nextReady = (ServerSocketChannel) key .channel(); // 获取客户端套接字 Socket s = nextReady.accept().socket(); // 设置对应的通道为异步方式并注册感兴趣事件 s.getChannel().configureBlocking(false); SelectionKey readWriteKey = s.getChannel().register( this.selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE); // 将注册的事件与该套接字联系起来 readWriteKey.attach(s); // 将当前建立连接的客户端套接字及对应的通道存放在哈希表//clientChannelMap中 this.clientChannelMap.put(s, new ClientChInstance(s .getChannel())); } else if (key.isReadable()) {// 如果是通道读准备好事件 System.out.println("Readable"); // 取得选择键对应的通道和套接字 SelectableChannel nextReady = (SelectableChannel) key .channel(); Socket socket = (Socket) key.attachment(); // 处理该事件,处理方法已封装在类ClientChInstance中 this.readFromChannel(socket.getChannel(), (ClientChInstance) this.clientChannelMap .get(socket)); } else if (key.isWritable()) {// 如果是通道写准备好事件 System.out.println("writeable"); // 取得套接字后处理,方法同上 Socket socket = (Socket) key.attachment(); SocketChannel channel = (SocketChannel) socket.getChannel(); // this.writeToChannel(channel, "This is from server!"); this.writeToChannel(channel, data); } } } } // 对通道的写操作 public void writeToChannel(SocketChannel channel, String message) throws IOException { ByteBuffer buf = ByteBuffer.wrap(message.getBytes()); int nbytes = channel.write(buf); } // 对通道的读操作 public void readFromChannel(SocketChannel channel, ClientChInstance clientInstance) throws IOException, InterruptedException { ByteBuffer byteBuffer = null; try{ byteBuffer = ByteBuffer.allocate(BUFFERSIZE); int nbytes = channel.read(byteBuffer); }catch(Exception e){ clientChannelMap.remove(channel.socket()); channel.close(); e=null; return; } byteBuffer.flip(); String result = this.decode(byteBuffer); // 当客户端发出”@exit”退出命令时,关闭其通道 if (result.indexOf("@exit") >= 0||result.indexOf("q")>=0) { channel.close(); } // else if(result.indexOf("@close") >= 0){//关闭服务 // channel.close(); // this.finalize(); // } else { clientInstance.append(result.toString()); // 读入一行完毕,执行相应操作 if (result.indexOf("\n") >= 0) { System.out.println("client input" + result); clientInstance.execute(); } } } // 该类封装了怎样对客户端的通道进行操作,具体实现可以通过重载execute()方法 public class ClientChInstance { SocketChannel channel; StringBuffer buffer = new StringBuffer(); public ClientChInstance(SocketChannel channel) { this.channel = channel; } public void execute() throws IOException { String message = "This is response after reading from channel!"; writeToChannel(this.channel, message); buffer = new StringBuffer(); } // 当一行没有结束时,将当前字窜置于缓冲尾 public void append(String values) { buffer.append(values); } } // 主程序 public static void main(String[] args) { NBServer nbServer = new NBServer(8090); try { nbServer.initialize(); } catch (Exception e) { e.printStackTrace(); System.exit(-1); } try { nbServer.portListening("This is from server!"); } catch (Exception e) { e.printStackTrace(); } } } 我写的客户端: package org.scorpion.scoket; import java.io.OutputStream; import java.net.Socket; public class TCPClient { public static void main(String[] args) throws Exception { Socket s = new Socket("172.22.71.146", 8000); OutputStream os = s.getOutputStream(); byte[] by="ksfsksjfklsdjflsdj".getBytes(); os.write(by); s.close(); } }

【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

java1.8使用socket的问题

今天在测试一个socket客户端的时候出现了一个问题,就是socket的输出流如果不关闭的话,那么消息就发不到服务端,write和flush方法都没有作用,最开始是设置了读超时,等到客户端读超时后到finnaly里面关闭输出流的时候,服务端才收到客户端的消息,然后在flush后面加上socket.shutdownoutputstream,服务端也能够及时收到消息,反过来服务端给客户端回信息也是一样,也要调用shutdownoutputstream客户端才能读到消息,请问有人知道是什么原因吗 代码如下,其中shutdownoutputstream是出现问题后填上的: 服务端 ----------------------------------------------------------------- public class ServerTest { public static void main(String[] a) throws IOException, InterruptedException { ServerSocket server = new ServerSocket(); server.bind(new InetSocketAddress(1287)); while (true) { Socket socket = server.accept(); BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); StringBuilder sb = new StringBuilder(); String temp = null; long b=System.currentTimeMillis(); while (StringUtils.isNotBlank((temp = br.readLine()))) { sb.append(temp); } long e=System.currentTimeMillis(); System.out.println(e-b); System.out.println(sb.toString()); // Thread.sleep(2000); System.out.println("return.........."); bw.write("return.........."); bw.flush(); socket.shutdownOutput(); } } } 客户端 ------------------------------------------------ public static String send(String message, String serverIp, int port, int connectTimeout, int readTimeout, String encoding) throws Exception { Socket socket = null; if (logger.isDebugEnabled()) { logger.debug("主机信息:ip=" + serverIp + ",端口=" + port + ",发送报文:" + message); } try { socket = new Socket(); socket.connect(new InetSocketAddress(serverIp, port), connectTimeout); socket.setSoTimeout(readTimeout); socket.setSoLinger(true, 1); socket.setTcpNoDelay(true); BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); out.write(message); out.flush(); socket.shutdownOutput(); StringBuilder sb = new StringBuilder(); String temp = null; while (StringUtils.isNotBlank((temp = in.readLine()))) { sb.append(temp); } if (logger.isDebugEnabled()) { logger.debug("接收应答:" + sb.toString()); } return sb.toString(); } catch (Exception e) { throw e; } finally { if (socket != null) { socket.close(); } } }

Java Socket网络通信问题,向百度发送数据(学习socket中~)

我在本地客户端向百度某个端口(如:80)发送一个数据(例如字符a),百度会返回什么信息吗? 测了一下,并没有什么回应。那么我在本地客户端怎么做,百度才会返回一些信息 (例如:时间、网页新闻之类的消息)

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

Vue + Spring Boot 项目实战(十九):Web 项目优化解决方案

快来一起探索如何打脸我们的破项目,兄弟姐妹们把害怕打在公屏上!

你连存活到JDK8中著名的Bug都不知道,我怎么敢给你加薪

CopyOnWriteArrayList.java和ArrayList.java,这2个类的构造函数,注释中有一句话 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 public ArrayList(Collection&lt;? ...

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

CSDN:因博主近期注重写专栏文章(已超过150篇),订阅博主专栏人数在突增,近期很有可能提高专栏价格(已订阅的不受影响),提前声明,敬请理解!

CSDN:因博主近期注重写专栏文章(已超过150篇),订阅博主专栏人数在突增,近期很有可能提高专栏价格(已订阅的不受影响),提前声明,敬请理解! 目录 博客声明 大数据了解博主粉丝 博主的粉丝群体画像 粉丝群体性别比例、年龄分布 粉丝群体学历分布、职业分布、行业分布 国内、国外粉丝群体地域分布 博主的近期访问每日增量、粉丝每日增量 博客声明 因近期博主写专栏的文章越来越多,也越来越精细,逐步优化文章。因此,最近一段时间,订阅博主专栏的人数增长也非常快,并且专栏价

一个HashMap跟面试官扯了半个小时

一个HashMap能跟面试官扯上半个小时 关注 安琪拉的博客 1.回复面试领取面试资料 2.回复书籍领取技术电子书 3.回复交流领取技术电子书 前言 HashMap应该算是Java后端工程师面试的必问题,因为其中的知识点太多,很适合用来考察面试者的Java基础。 开场 面试官: 你先自我介绍一下吧! 安琪拉: 我是安琪拉,草丛三婊之一,最强中单(钟馗不服)!哦,不对,串场了,我是**,目...

我说我不会算法,阿里把我挂了。

不说了,字节跳动也反手把我挂了。

记录下入职中软一个月(外包华为)

我在年前从上一家公司离职,没想到过年期间疫情爆发,我也被困在家里,在家呆着的日子让人很焦躁,于是我疯狂的投简历,看面试题,希望可以进大公司去看看。 我也有幸面试了我觉得还挺大的公司的(虽然不是bat之类的大厂,但是作为一名二本计算机专业刚毕业的大学生bat那些大厂我连投简历的勇气都没有),最后选择了中软,我知道这是一家外包公司,待遇各方面甚至不如我的上一家公司,但是对我而言这可是外包华为,能...

面试:第十六章:Java中级开发

HashMap底层实现原理,红黑树,B+树,B树的结构原理 Spring的AOP和IOC是什么?它们常见的使用场景有哪些?Spring事务,事务的属性,传播行为,数据库隔离级别 Spring和SpringMVC,MyBatis以及SpringBoot的注解分别有哪些?SpringMVC的工作原理,SpringBoot框架的优点,MyBatis框架的优点 SpringCould组件有哪些,他们...

培训班出来的人后来都怎么样了?(二)

接着上回说,培训班学习生涯结束了。后面每天就是无休止的背面试题,不是没有头脑的背,培训公司还是有方法的,现在回想当时背的面试题好像都用上了,也被问到了。回头找找面试题,当时都是打印下来天天看,天天背。 不理解呢也要背,面试造飞机,上班拧螺丝。班里的同学开始四处投简历面试了,很快就有面试成功的,刚开始一个,然后越来越多。不知道是什么原因,尝到胜利果实的童鞋,不满足于自己通过的公司,嫌薪水要少了,选择...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

工作八年,月薪60K,裸辞两个月,投简历投到怀疑人生!

近日,有网友在某职场社交平台吐槽,自己裸辞两个月了,但是找工作却让自己的心态都要崩溃了,全部无果,不是已查看无回音,就是已查看不符合。 “工作八年,两年一跳,裸辞两个月了,之前月薪60K,最近找工作找的心态崩了!所有招聘工具都用了,全部无果,不是已查看无回音,就是已查看不符合。进头条,滴滴之类的大厂很难吗???!!!投简历投的开始怀疑人生了!希望 可以收到大厂offer” 先来看看网...

大牛都会用的IDEA调试技巧!!!

导读 前天面试了一个985高校的实习生,问了他平时用什么开发工具,他想也没想的说IDEA,于是我抛砖引玉的问了一下IDEA的调试用过吧,你说说怎么设置断点...

都前后端分离了,咱就别做页面跳转了!统统 JSON 交互

文章目录1. 无状态登录1.1 什么是有状态1.2 什么是无状态1.3 如何实现无状态1.4 各自优缺点2. 登录交互2.1 前后端分离的数据交互2.2 登录成功2.3 登录失败3. 未认证处理方案4. 注销登录 这是本系列的第四篇,有小伙伴找不到之前文章,松哥给大家列一个索引出来: 挖一个大坑,Spring Security 开搞! 松哥手把手带你入门 Spring Security,别再问密...

97年世界黑客编程大赛冠军作品(大小仅为16KB),惊艳世界的编程巨作

这是世界编程大赛第一名作品(97年Mekka ’97 4K Intro比赛)汇编语言所写。 整个文件只有4095个字节, 大小仅仅为16KB! 不仅实现了3D动画的效果!还有一段震撼人心的背景音乐!!! 内容无法以言语形容,实在太强大! 下面是代码,具体操作看最后! @echo off more +1 %~s0|debug e100 33 f6 bf 0 20 b5 10 f3 a5...

程序员是做全栈工程师好?还是专注一个领域好?

昨天,有位大一的同学私信我,说他要做全栈工程师。 我一听,这不害了孩子么,必须制止啊。 谁知,讲到最后,更确定了他做全栈程序员的梦想。 但凡做全栈工程师的,要么很惨,要么很牛! 但凡很牛的,绝不是一开始就是做全栈的! 全栈工程师听起来好听,但绝没有你想象的那么简单。 今天听我来给你唠,记得帮我点赞哦。 一、全栈工程师的职责 如果你学习编程的目的只是玩玩,那随意,想怎么学怎么学。...

不要再到处使用 === 了

我们知道现在的开发人员都使用 === 来代替 ==,为什么呢?我在网上看到的大多数教程都认为,要预测 JavaScript 强制转换是如何工作这太复杂了,因此建议总是使用===。这些都...

什么是a站、b站、c站、d站、e站、f站、g站、h站、i站、j站、k站、l站、m站、n站?00后的世界我不懂!

A站 AcFun弹幕视频网,简称“A站”,成立于2007年6月,取意于Anime Comic Fun,是中国大陆第一家弹幕视频网站。A站以视频为载体,逐步发展出基于原生内容二次创作的完整生态,拥有高质量互动弹幕,是中国弹幕文化的发源地;拥有大量超粘性的用户群体,产生输出了金坷垃、鬼畜全明星、我的滑板鞋、小苹果等大量网络流行文化,也是中国二次元文化的发源地。 B站 全称“哔哩哔哩(bilibili...

十个摸鱼,哦,不对,是炫酷(可以玩一整天)的网站!!!

文章目录前言正文**1、Kaspersky Cyberthreat real-time map****2、Finding Home****3、Silk – Interactive Generative Art****4、Liquid Particles 3D****5、WINDOWS93****6、Staggering Beauty****7、Ostagram图片生成器网址****8、全历史网址*...

终于,月薪过5万了!

来看几个问题想不想月薪超过5万?想不想进入公司架构组?想不想成为项目组的负责人?想不想成为spring的高手,超越99%的对手?那么本文内容是你必须要掌握的。本文主要详解bean的生命...

用了这个 IDE 插件,5分钟解决前后端联调!

点击上方蓝色“程序猿DD”,选择“设为星标”回复“资源”获取独家整理的学习资料!作者 |李海庆我是一个 Web 开发前端工程师,受到疫情影响,今天是我在家办公的第78天。开发了两周,...

大厂的 404 页面都长啥样?最后一个笑了...

每天浏览各大网站,难免会碰到404页面啊。你注意过404页面么?猿妹搜罗来了下面这些知名网站的404页面,以供大家欣赏,看看哪个网站更有创意: 正在上传…重新上传取消 腾讯 正在上传…重新上传取消 网易 淘宝 百度 新浪微博 正在上传…重新上传取消 新浪 京东 优酷 腾讯视频 搜...

自从喜欢上了B站这12个UP主,我越来越觉得自己是个废柴了!

不怕告诉你,我自从喜欢上了这12个UP主,哔哩哔哩成为了我手机上最耗电的软件,几乎每天都会看,可是吧,看的越多,我就越觉得自己是个废柴,唉,老天不公啊,不信你看看…… 间接性踌躇满志,持续性混吃等死,都是因为你们……但是,自己的学习力在慢慢变强,这是不容忽视的,推荐给你们! 都说B站是个宝,可是有人不会挖啊,没事,今天咱挖好的送你一箩筐,首先啊,我在B站上最喜欢看这个家伙的视频了,为啥 ,咱撇...

代码注释如此沙雕,会玩还是你们程序员!

某站后端代码被“开源”,同时刷遍全网的,还有代码里的那些神注释。 我们这才知道,原来程序员个个都是段子手;这么多年来,我们也走过了他们的无数套路… 首先,产品经理,是永远永远吐槽不完的!网友的评论也非常扎心,说看这些代码就像在阅读程序员的日记,每一页都写满了对产品经理的恨。 然后,也要发出直击灵魂的质问:你是尊贵的付费大会员吗? 这不禁让人想起之前某音乐app的穷逼Vip,果然,穷逼在哪里都是...

Java14 新特性解读

Java14 已于 2020 年 3 月 17 号发布,官方特性解读在这里:https://openjdk.java.net/projects/jdk/14/以下是个人对于特性的中文式...

前端还能这么玩?(女朋友生日,用前端写了一个好玩的送给了她,高兴坏了)

前端还能这么玩?(女朋友生日,用前端写了一个好玩的送给了她,高兴坏了)

爬虫(101)爬点重口味的

小弟最近在学校无聊的很哪,浏览网页突然看到一张图片,都快流鼻血。。。然后小弟冥思苦想,得干一点有趣的事情python 爬虫库安装https://s.taobao.com/api?_ks...

工作两年简历写成这样,谁要你呀!

作者:小傅哥 博客:https://bugstack.cn 沉淀、分享、成长,让自己和他人都能有所收获! 一、前言 最近有伙伴问小傅哥,我的简历怎么投递了都没有反应,心里慌的很呀。 工作两年了目前的公司没有什么大项目,整天的维护别人的代码,有坑也不让重构,都烦死了。荒废我一身技能无处施展,投递的简历也没人看。我是不动物园里的猩猩,狒狒了! 我要加班,我要996,我要疯狂编码,求给我个机会… ...

相关热词 c# cad插入影像 c#设计思想 c#正则表达式 转换 c#form复制 c#写web c# 柱形图 c# wcf 服务库 c#应用程序管理器 c#数组如何赋值给数组 c#序列化应用目的博客园
立即提问