How to use Java to develop Websocket file transfer function
Dec 17, 2023 pm 03:18 PMHow to use Java to develop Websocket file transfer function
With the development of the Internet, file transfer has become an indispensable part of daily work and life. As a communication protocol that establishes a persistent connection between the browser and the server, Websocket has the characteristics of real-time and two-way transmission, making it an ideal choice for file transfer. This article will introduce how to use Java to develop Websocket file transfer function and provide specific code examples.
1. Create a Websocket server
To implement the file transfer function, you first need to create a Websocket server to receive and process client requests. The following is a sample code for creating a Websocket server using Java's Tomcat framework:
@ServerEndpoint("/upload") public class FileUploadServer { @OnOpen public void onOpen(Session session) { System.out.println("Client connected: " + session.getId()); } @OnMessage public void onMessage(ByteBuffer byteBuffer, Session session) throws IOException { Path path = Paths.get("uploads", session.getId() + ".jpg"); Files.write(path, byteBuffer.array()); System.out.println("File uploaded: " + path.toString()); } @OnClose public void onClose(Session session) { System.out.println("Client disconnected: " + session.getId()); } @OnError public void onError(Throwable e) { e.printStackTrace(); } }
In the above code, we use the @ServerEndpoint
annotation to annotate a Websocket server and specify client access The URL is /upload
. The server side provides four methods to handle client connections, receive file data, disconnect and handle exceptions respectively. Among them, the onMessage
method is called when receiving file data, saves the file to the uploads
folder, and uses the client's ID as the file name.
2. Create a Websocket client
Next, we need to create a Websocket client to send file data to the server. Below is the sample code for creating a Websocket client using Java's JavaFX framework:
public class FileUploadClient extends Application { private static final String SERVER_URI = "ws://localhost:8080/upload"; private WebSocketClient client; public static void main(String[] args) { launch(args); } @Override public void start(Stage primaryStage) { try { URI uri = new URI(SERVER_URI); client = new WebSocketClient(uri) { @Override public void onOpen(ServerHandshake handshakedata) { System.out.println("Connected to server"); } @Override public void onMessage(String message) { System.out.println("Received message: " + message); } @Override public void onClose(int code, String reason, boolean remote) { System.out.println("Disconnected from server"); } @Override public void onError(Exception ex) { ex.printStackTrace(); } }; client.connect(); } catch (URISyntaxException e) { e.printStackTrace(); } } public void uploadFile(Path path) throws IOException { byte[] bytes = Files.readAllBytes(path); client.send(bytes); System.out.println("File uploaded: " + path.toString()); } }
In the above code, we have created a simple interface using JavaFX by connecting to the server-side URL ws://localhost :8080/upload
, and implements four methods of the client to handle various stages of communication with the server. The uploadFile
method is used to read the specified file into a byte array and send it to the server through the client.
3. Start the server and client
After completing the server and client code, we need to start them to test the file transfer function. First, you need to deploy the server-side code to Tomcat or other server that supports Java web applications, and start the server. You can then run the client code directly, launching the JavaFX application.
After the program runs, the client will establish a connection with the server, and the "Connected to server" prompt message will be printed on the console. Then, we can select the file to upload through the file selector on the interface and click the "Upload" button. The client will send the selected file to the server and print out the "File uploaded: file path" prompt message on the console.
4. Summary
This article introduces how to use Java to develop the Websocket file transfer function, and provides specific code examples for the server and client. Through the two-way communication and real-time nature of the Websocket protocol, we are able to achieve fast, efficient, and secure file transfer. I believe readers can further explore and apply Websocket file transfer technology based on the sample code provided in this article.
The above is the detailed content of How to use Java to develop Websocket file transfer function. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undress AI Tool
Undress images for free

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

The settings.json file is located in the user-level or workspace-level path and is used to customize VSCode settings. 1. User-level path: Windows is C:\Users\\AppData\Roaming\Code\User\settings.json, macOS is /Users//Library/ApplicationSupport/Code/User/settings.json, Linux is /home//.config/Code/User/settings.json; 2. Workspace-level path: .vscode/settings in the project root directory

To correctly handle JDBC transactions, you must first turn off the automatic commit mode, then perform multiple operations, and finally commit or rollback according to the results; 1. Call conn.setAutoCommit(false) to start the transaction; 2. Execute multiple SQL operations, such as INSERT and UPDATE; 3. Call conn.commit() if all operations are successful, and call conn.rollback() if an exception occurs to ensure data consistency; at the same time, try-with-resources should be used to manage resources, properly handle exceptions and close connections to avoid connection leakage; in addition, it is recommended to use connection pools and set save points to achieve partial rollback, and keep transactions as short as possible to improve performance.

DependencyInjection(DI)isadesignpatternwhereobjectsreceivedependenciesexternally,promotingloosecouplingandeasiertestingthroughconstructor,setter,orfieldinjection.2.SpringFrameworkusesannotationslike@Component,@Service,and@AutowiredwithJava-basedconfi

TheJVMenablesJava’s"writeonce,runanywhere"capabilitybyexecutingbytecodethroughfourmaincomponents:1.TheClassLoaderSubsystemloads,links,andinitializes.classfilesusingbootstrap,extension,andapplicationclassloaders,ensuringsecureandlazyclassloa

Use classes in the java.time package to replace the old Date and Calendar classes; 2. Get the current date and time through LocalDate, LocalDateTime and LocalTime; 3. Create a specific date and time using the of() method; 4. Use the plus/minus method to immutably increase and decrease the time; 5. Use ZonedDateTime and ZoneId to process the time zone; 6. Format and parse date strings through DateTimeFormatter; 7. Use Instant to be compatible with the old date types when necessary; date processing in modern Java should give priority to using java.timeAPI, which provides clear, immutable and linear

ChromecanopenlocalfileslikeHTMLandPDFsbyusing"Openfile"ordraggingthemintothebrowser;ensuretheaddressstartswithfile:///;2.SecurityrestrictionsblockAJAX,localStorage,andcross-folderaccessonfile://;usealocalserverlikepython-mhttp.server8000tor

Networkportsandfirewallsworktogethertoenablecommunicationwhileensuringsecurity.1.Networkportsarevirtualendpointsnumbered0–65535,withwell-knownportslike80(HTTP),443(HTTPS),22(SSH),and25(SMTP)identifyingspecificservices.2.PortsoperateoverTCP(reliable,c

Pre-formanceTartuptimeMoryusage, Quarkusandmicronautleadduetocompile-Timeprocessingandgraalvsupport, Withquarkusoftenperforminglightbetterine ServerLess scenarios.2.Thyvelopecosyste,
