java連接服務器,java連接服務器執行shell腳本

本文目錄一覽：

• 1、java中如何實現多個客戶端與服務器連接
• 2、怎麼用java代碼連接到服務器？
• 3、怎麼用java代碼連接到服務器
• 4、kafka java 通過url連接服務器
• 5、本地java項目如何連接阿里雲服務器上的mysql？
• 6、java.net.connectexception無法連接至服務器

java中如何實現多個客戶端與服務器連接

服務器端可以採用多線程處理客戶請求，例如：

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

}

}

}

}

怎麼用java代碼連接到服務器？

用Socket類去連接\x0d\x0a String ip = “192.168.0.57”;\x0d\x0a int port=7000;\x0d\x0a InputStream in;\x0d\x0a OutputStream out;\x0d\x0aSocket sock = null; \x0d\x0a try {\x0d\x0a sock = new Socket(ip,port);\x0d\x0a sock.setSoTimeout(60*1000);//設置超時\x0d\x0a this.in = sock.getInputStream();\x0d\x0a this.out = sock.getOutputStream();\x0d\x0a } catch (Exception e) {\x0d\x0a throw new Exception(“與終端連接失敗!”);\x0d\x0a }

怎麼用java代碼連接到服務器

首先就肯定要知道ServerSocket，服務端的服務端口以及服務器的地址。

然後再用 Socket socket=new Socket(port,address);

最後，如果你需要接收數據之類的，就用socket.getInputStream(),發送數據用socket.getOutputStream()

kafka java 通過url連接服務器

可以連接到一個網絡服務器並且能夠從這個服務器下載指定的URL，程序中直接使用HTTP協議。程序將定義一個輸出流，下載的URL的內容將來被寫入這個流，通過socket來獲得輸入和輸出流：

view sourceprint?

01 import java.io.*;

02 import java.net.*;

03 public class HttpClient {

04 public static void main(String[] args) {

05 try {

06 // Demo參數:

07 if ((args.length != 1) (args.length != 2))

08 throw new IllegalArgumentException(“Wrong number of args”);

09 //定義輸出流，下載的URL內容被寫入這個流

10 OutputStream to_file;

11 if (args.length == 2) to_file = new FileOutputStream(args[1]);

12 else to_file = System.out;

13 //使用URL類來把用戶指定的URL解析成幾個部分

14 URL url = new URL(args[0]);

15 String protocol = url.getProtocol();

16 if (!protocol.equals(“http”)) // 檢驗是否滿足支持的協議

17 throw new IllegalArgumentException(“Must use ‘http:’ protocol”);

18 String host = url.getHost();

19 int port = url.getPort();

20 if (port == -1) port = 80; //如果沒有指定端口，用默認端口

21 String filename = url.getFile();

22 // 打開一個連接到指定主機和端口的網絡socket連接

23 Socket socket = new Socket(host, port);

24 // 通過socket來獲得輸入和輸出流

25 InputStream from_server = socket.getInputStream();

26 PrintWriter to_server = new PrintWriter(socket.getOutputStream());

27

28 // 發送HTTP GET命令給網絡服務器，指定要下載的文件

29 // 使用了一個老版本非常簡單的HTTP協議

30 to_server.print(“GET ” + filename + “\n\n”);

31 to_server.flush(); // 立即發送

32 // 現在讀取服務器的響應，把接收到的內容寫入文件

33 byte[] buffer = new byte[4096];

34 int bytes_read;

35 while((bytes_read = from_server.read(buffer)) != -1)

36 to_file.write(buffer, 0, bytes_read);

37 // 當服務器關閉連接時，也關閉stuff

38 socket.close();

39 to_file.close();

40 }

41 catch (Exception e) { // 發布錯誤

42 System.err.println(e);

43 System.err.println(“Usage: java HttpClient URL [filename]”);

44 }

45 }

46 }

本地java項目如何連接阿里雲服務器上的mysql？

首先您需要保證您本地Java項目是可以聯網的，然後在mysql的連接中輸入阿里雲服務器的地址以及數據庫名和密碼就行。

java.net.connectexception無法連接至服務器

出現這個問題的原因，就是連接遠程服務的網絡不通或者是端口有問題導致的。

問題原因排查：

第一步：在黑窗口中輸入 ：ping ip是否連通；如果沒問題進行第二步。

第二步：在黑窗口中輸入：telnet ip 端口，查看端口是否可以訪問，如果沒問題進行第三步。

第三步：在黑窗口輸入：ping 地址（此地址就是conn的地址）。

備註：以上三步肯定能夠排查出問題原因的。如果還是不行，那麼就是代碼編寫的有問題。