怎么用java代码连接到服务器?

怎么用java代码连接到服务器?,第1张

用Socket类去连接\x0d\x0aStringip="192.168.0.57"\x0d\x0aintport=7000\x0d\x0aInputStreamin\x0d\x0aOutputStreamout\x0d\x0aSocketsock=null\x0d\x0atry{\x0d\x0asock=newSocket(ip,port)\x0d\x0asock.setSoTimeout(60*1000)//设置超时\x0d\x0athis.in=sock.getInputStream()\x0d\x0athis.out=sock.getOutputStream()\x0d\x0a}catch(Exceptione){\x0d\x0athrownewException("与终端连接失败!")\x0d\x0a}

服务器端可以采用多线程处理客户请求,例如:

package threadPool

import java.io.BufferedReader

import java.io.IOException

import java.io.InputStream

import java.io.InputStreamReader

import java.io.OutputStream

import java.io.PrintWriter

import java.net.ServerSocket

import java.net.Socket

import java.util.concurrent.ExecutorService

import java.util.concurrent.Executors

public class ThreadPoolServer {

private int port = 8000

private ServerSocket serverSocket

private ExecutorService executorService //线程池

private final int POOL_SIZE = 4 //单个CPU时线程池中的工作线程数目

public ThreadPoolServer() throws IOException{

serverSocket = new ServerSocket(port)

//创建线程池

//Runtime 的availableProcessors()方法返回当前系统CPU的数目

//系统CPU越多,线程池中的工作线程数目越多

executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()*POOL_SIZE)

System.out.println("服务器已启动!!")

}

public void service(){

while(true){

Socket socket = null

try{

socket = serverSocket.accept()

executorService.execute(new Handler(socket))

}catch(IOException e){

e.printStackTrace()

}

}

}

public static void main(String[] args) {

try {

new ThreadPoolServer().service()

} catch (IOException e) {

e.printStackTrace()

}

}

}

class Handler implements Runnable {

private Socket socket

public Handler(Socket socket) {

this.socket = socket

}

private PrintWriter getWriter(Socket socket) throws IOException {

OutputStream socketOut = socket.getOutputStream()

return new PrintWriter(socketOut, true)

}

private BufferedReader getReader(Socket socket) throws IOException {

InputStream socketIn = socket.getInputStream()

return new BufferedReader(new InputStreamReader(socketIn))

}

public String echo(String msg) {

return "echo:" + msg

}

@Override

public void run() {

try {

System.out.println("New connection accepted:" + socket.getInetAddress() + ":" + socket.getPort())

BufferedReader br = getReader(socket)

PrintWriter pw = getWriter(socket)

String msg = null

while ((msg = br.readLine()) != null) {

System.out.println(msg)

pw.println(echo(msg))

if (msg.equals("bye")) {

break

}

}

} catch (IOException e) {

e.printStackTrace()

} finally {

try {

if (socket != null)

socket.close()

} catch (IOException e) {

e.printStackTrace()

}

}

}

}

出现这个问题的原因,就是连接远程服务的网络不通或者是端口有问题导致的。

问题原因排查:

第一步:在黑窗口中输入 :ping ip是否连通;如果没问题进行第二步。

第二步:在黑窗口中输入:telnet ip 端口,查看端口是否可以访问,如果没问题进行第三步。

第三步:在黑窗口输入:ping 地址(此地址就是conn的地址)。

备注:以上三步肯定能够排查出问题原因的。如果还是不行,那么就是代码编写的有问题。


欢迎分享,转载请注明来源:夏雨云

原文地址:https://www.xiayuyun.com/zonghe/82937.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2023-03-04
下一篇2023-03-04

发表评论

登录后才能评论

评论列表(0条)

    保存