「java连接服务器」java连接服务器执行shell脚本

admin 2023-01-13 23:00:12 471

本篇文章给大家谈谈java连接服务器，以及java连接服务器执行shell脚本对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

1、java中如何实现多个客户端与服务器连接
2、怎么用java程序连接NTP服务器？
3、本地java项目如何连接阿里云服务器上的mysql？
4、javaswing如何连接服务器
5、kafka java 通过url连接服务器
6、怎么用java代码连接到服务器？

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程序连接NTP服务器？

Java软件包内在支持的网络协议为TCP/IP，也是当今最流行的广域网/局域网协议。Java有关网络的类及接口定义在java.net包中。客户端软件通常使用 java.net包中的核心类Socket与服务器的某个端口建立连接，而服务器程序不同于客户机，它需要初始化一个端口进行监听，遇到连接呼叫，才与相应的客户机建立连接。Java.net包的ServerSocket类包含了编写服务器系统所需的一切。下面给出ServerSocket类的部分定义。

public class ServerSocket {

public ServerSocket(int port)

throws IOException ；

public Socket accept() throws IOException ；

public InetAddress getInetAddress() ；

public int getLocalPort() ；

public void close() throws IOException ；

public synchronized void setSoTimeout

(int timeout) throws SocketException ；

public synchronized int

getSoTimeout() throws IOException ；

}

ServerSocket 构造器是服务器程序运行的基础，它将参数port指定的端口初始化作为该服务器的端口，监听客户机连接请求。Port的范围是0到65536，但0到 1023是标准Internet协议保留端口，而且在Unix主机上，这些端口只有root用户可以使用。一般自定义的端口号在8000到16000之间。仅初始化了ServerSocket还是远远不够的，它没有同客户机交互的套接字（Socket），因此需要调用该类的accept方法接受客户呼叫。Accept()方法直到有连接请求才返回通信套接字(Socket)的实例。通过这个实例的输入、输出流，服务器可以接收用户指令，并将相应结果回应客户机。ServerSocket类的getInetAddress和getLocalPort方法可得到该服务器的IP地址和端口。 setSoTimeout和getSoTimeout方法分别是设置和得到服务器超时设置，如果服务器在timout设定时间内还未得到accept方法返回的套接字实例，则抛出IOException的异常。

Java的多线程可谓是Java编程的精华之一，运用得当可以极大地改善程序的响应时间，提高程序的并行性。在服务器程序中，由于往往要接收不同客户机的同时请求或命令，因此可以对每个客户机的请求生成一个命令处理线程，同时对各用户的指令作出反应。在一些较复杂的系统中，我们还可以为每个数据库查询指令生成单独的线程，并行对数据库进行操作。实践证明，采用多线程设计可以很好的改善系统的响应，并保证用户指令执行的独立性。由于Java本身是"线程安全"的，因此有一条编程原则是能够独立在一个线程中完成的操作就应该开辟一个新的线程。

Java中实现线程的方式有两种，一是生成Thread类的子类，并定义该子类自己的run方法，线程的操作在方法run中实现。但我们定义的类一般是其他类的子类，而Java又不允许多重继承，因此第二种实现线程的方法是实现Runnable接口。通过覆盖Runnable接口中的run方法实现该线程的功能。本文例子采用第一种方法实现线程。

二、多线程服务器程序举例

以下是我们在项目中采用的多线程服务器程序的架构，可以在此基础上对命令进行扩充。本例未涉及数据库。如果在线程运行中需要根据用户指令对数据库进行更新操作，则应注意线程间的同步问题，使同一更新方法一次只能由一个线程调用。这里我们有两个类，receiveServer包含启动代码（main()），并初始化ServerSocket的实例，在accept方法返回用户请求后，将返回的套接字（Socket）交给生成的线程类serverThread 的实例，直到该用户结束连接。

//类receiveServer

import java.io.*;

import java.util.*;

import java.net.*;

public class receiveServer{

final int RECEIVE_PORT=9090;

//该服务器的端口号

//receiveServer的构造器

public receiveServer() {

ServerSocket rServer=null;

//ServerSocket的实例

Socket request=null; //用户请求的套接字

Thread receiveThread=null;

try{

rServer=new ServerSocket(RECEIVE_PORT);

//初始化ServerSocket

System.out.println("Welcome to the server!");

System.out.println(new Date());

System.out.println("The server is ready!");

System.out.println("Port: "+RECEIVE_PORT);

while(true){ //等待用户请求

request=rServer.accept();

//接收客户机连接请求

receiveThread=new serverThread(request);

//生成serverThread的实例

receiveThread.start();

//启动serverThread线程

}

}catch(IOException e){

System.out.println(e.getMessage());}

}

public static void main(String args[]){

new receiveServer();

} //end of main

} //end of class

//类serverThread

import java.io.*;

import java.net.*;

class serverThread extends Thread {

Socket clientRequest;

//用户连接的通信套接字

BufferedReader input; //输入流

PrintWriter output; //输出流

public serverThread(Socket s)

{ //serverThread的构造器

this.clientRequest=s;

//接收receiveServer传来的套接字

InputStreamReader reader;

OutputStreamWriter writer;

try{ //初始化输入、输出流

reader=new InputStreamReader

(clientRequest.getInputStream());

writer=new OutputStreamWriter

(clientRequest.getOutputStream());

input=new BufferedReader(reader);

output=new PrintWriter(writer,true);

}catch(IOException e){

System.out.println(e.getMessage());}

output.println("Welcome to the server!");

//客户机连接欢迎词

output.println("Now is:

"+new java.util.Date()+" "+

"Port:"+clientRequest.getLocalPort());

output.println("What can I do for you?");

}

public void run(){ //线程的执行方法

String command=null; //用户指令

String str=null;

boolean done=false;

while(!done){

try{

str=input.readLine(); //接收客户机指令

}catch(IOException e){

System.out.println(e.getMessage());}

command=str.trim().toUpperCase();

if(str==null || command.equals("QUIT"))

//命令quit结束本次连接

done=true;

else if(command.equals("HELP")){

//命令help查询本服务器可接受的命令

output.println("query");

output.println("quit");

output.println("help");

}

else if(command.startsWith("QUERY"))

{ //命令query

output.println("OK to query something!");

}

//else if …….. //在此可加入服务器的其他指令

else if(!command.startsWith("HELP")

!command.startsWith("QUIT")

!command.startsWith("QUERY")){

output.println("Command not Found!

Please refer to the HELP!");

}

}//end of while

try{

clientRequest.close(); //关闭套接字

}catch(IOException e){

System.out.println(e.getMessage());

}

command=null;

}//end of run

启动该服务器程序后，可用telnet machine port命令连接，其中machine为本机名或地址，port为程序中指定的端口。也可以编写特定的客户机软件通过TCP的Socket套接字建立连接

本地java项目如何连接阿里云服务器上的mysql？

首先您需要保证您本地Java项目是可以联网的，然后在mysql的连接中输入阿里云服务器的地址以及数据库名和密码就行。

javaswing如何连接服务器

具体实现步骤：

1、把jar文件复制进项目

2、用navicat建立数据库db_studentinfo,建立表student

3、新建项目Java，在str中建立包Second

4、建立类

Window.java

Add.java

Ask.java

Change.java

Delete.java

Look.java

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

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代码连接到服务器？

用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连接服务器和java连接服务器执行shell脚本的介绍到此就结束了，不知道你从中找到你需要的信息了吗？如果你还想了解更多这方面的信息，记得收藏关注本站。

标签：java连接服务器