Dieser Artikel teilt ein Beispiel für das Streaming von Java Socket Byte als Referenz. Der spezifische Inhalt ist wie folgt
Serverseite:
Paket com.yuan.socket; import Java.io. */Public Class TalkServer4Byte {private ServerSocket Server; private int port = 5020; public talkServer4Byte () {try {Server = new ServerSocket (Port); } catch (ioException e) {}} public void talk () {System.out.println ("Monitor Port:" + port); Socket Socket = Null; while (true) {try {// blockieren und wartet, eine neue Verbindungsinstanz für jede Anforderung erstellen. Empfangen socket = server.accept (); System.out.println ("Client -Adresse verbinden:" + socket.getRemotesocketadDress ()); // Decorative Stream BufferedReader verkaps den Eingangsstream (Empfangs -Client -Stream) BufferedInputStream Bis = New BufferedInputStream (Socket.getInputStream ()); DataNputStream dis = new DataNputStream (BIS); byte [] bytes = neues byte [1]; // Lesen Sie jeweils ein Byte ret = ""; while (dis.read (bytes)! = -1) {ret + = byTestohexString (bytes) + ""; if (dis.available () == 0) {// Eine Anforderung Dosen (ret); }}} catch (ioException e) {System.out.println (e.getMessage ()); } endlich {try {socket.close (); } catch (ioException e) {System.out.println (e.getMessage ()); }}}} public static void dosomething (string ret) {System.out.println (ret); } public static String byTestohexString (byte [] src) {StringBuilder StringBuilder = new StringBuilder (""); if (src == null || src.length <= 0) {return null; } für (int i = 0; i <src.length; i ++) {int v = src [i] & 0xff; String hv = Integer.ToHexString (v); if (hv.length () <2) {stringBuilder.Append (0); } StringBuilder.Append (HV); } return StringBuilder.toString (); } public static String bytesExString (byte [] b) {String ret = ""; für (int i = 0; i <B.Length; i ++) {String hex = Integer.tohexString (b [i] & 0xff); if (hex.length () == 1) {hex = '0' + hex; } ret += hex.touppercase (); } return ret; } public static void main (String [] args) {TalkServer4Byte Server = New TalkServer4Byte (); server.talk (); }} Client -Client -Code:
Paket com.yuan.socket; import java.io.datainputstream; import Java.io.dataoutputStream; Import Java.io.ioxception; Import Java.io.inputstream import Java.net.inputsocketaddress; Import Java.Net. 2016-09-17. */Public Class TalkClient4Byte {Private Socket Socket; private Socketaddress -Adresse; public talkClient4Byte () {try {socket = new Socket (); Adresse = new inetsocketaddress ("127.0.0.1", 5020); Socket.Connect (Adresse, 1000); } catch (ioException e) {e.printstacktrace (); }} public void talk () {try {// Verwenden Sie DataNputStream, um Eingabestromeingänge in Eingabestream OS = new DataNputStream (System.in) zu verringern; Byte [] B = neues Byte [1]; DataOutputStream dos = new DataOutputStream (Socket.getOutputStream ()); while (-1! = os.read (b)) {dos.write (b); // an den Client senden} dos.flush (); dos.close (); } catch (ioException e) {e.printstacktrace (); } endlich {try {socket.close (); } catch (ioException e) {}}} public static void main (string [] args) {talkClient4Byte client = new talkClient4Byte (); Client.Talk (); }}Das obige ist der gesamte Inhalt dieses Artikels. Ich hoffe, es wird für das Lernen aller hilfreich sein und ich hoffe, jeder wird Wulin.com mehr unterstützen.