首先，我们来看看QQ发送表情包的方法(发表情包不简单吗？不就是点击一下？)
当我们在待输入框里输入 " / " 的时候，我们发送有提示信息。
结果发现，当我们输入 "/xk"的时候，会直接定位到笑哭的这个表情。
因此我的想法是，当我输入 "//" 含有两个反斜杠的文本消息时，线程那边将会判断它是一个表情包。然后通过"//00","//01","//02"这类字符串，去提取字符串后两位的字符，然后去本地路径去调用图片表情包。因此："00" , "01" , "02" 就要成为图片的名字。否则匹配不方便。
图片名和路径如下：
线程判断和匹配如下：
Stage牛逼，模拟一切弹窗(主要是我太菜了)。
1 if(str.contains("//")){ 2 Platform.runLater(new Runnable(){ 3 public void run(){ 4 Stage stage = new Stage(); 5 BorderPane bp = new BorderPane(); 6 String[] strs=str.split("//"); 7 String img_name = strs[1]; 8 Image image = new Image("file:表情包/"+img_name+".jpg"); 9 ImageView iv = new ImageView(image); 10 bp.setCenter(iv); 11 Scene scene = new Scene(bp); 12 stage.setTitle("表情"); 13 stage.setScene(scene); 14 stage.centerOnScreen(); 15 stage.show(); 16 } 17 }); 18 }
完整代码如下：
1 package 测试; 2 3 import java.io.File; 4 import java.io.FileInputStream; 5 import java.io.FileOutputStream; 6 import java.io.IOException; 7 import java.io.InputStream; 8 import java.io.OutputStream; 9 import java.net.DatagramPacket; 10 import java.net.InetAddress; 11 import java.net.MulticastSocket; 12 import java.text.SimpleDateFormat; 13 import java.util.Date; 14 import java.util.Optional; 15 16 import javafx.application.Application; 17 import javafx.application.Platform; 18 import javafx.event.ActionEvent; 19 import javafx.scene.Scene; 20 import javafx.scene.control.Alert; 21 import javafx.scene.control.Button; 22 import javafx.scene.control.ButtonType; 23 import javafx.scene.control.Label; 24 import javafx.scene.control.ScrollPane; 25 import javafx.scene.control.TextArea; 26 import javafx.scene.control.TextField; 27 import javafx.scene.control.TitledPane; 28 import javafx.scene.image.Image; 29 import javafx.scene.image.ImageView; 30 import javafx.scene.layout.AnchorPane; 31 import javafx.scene.layout.BorderPane; 32 import javafx.scene.layout.VBox; 33 import javafx.scene.text.Font; 34 import javafx.stage.FileChooser; 35 import javafx.stage.Stage; 36 import sun.misc.BASE64Decoder; 37 import sun.misc.BASE64Encoder; 38 39 public class FX_UDP extends Application { 40 static InetAddress ia; 41 static MulticastSocket socket, socket2, socket1;// socket(6760) 42 // 聊天，socket1(6770) 43 // 窗口颤抖，socket2(6880) 图片流 44 static TextArea ta_1, ta_2; 45 static TextField tf_name; 46 static Stage s1; 47 48 public static void main(String[] args) { 49 try { 50 ia = InetAddress.getByName("228.9.6.7"); 51 socket = new MulticastSocket(6760); 52 socket.joinGroup(ia); 53 new Private_recive().start(); 54 new Image_recive().start(); 55 } catch (IOException e1) { 56 System.out.println("组播地址绑定失败"); 57 } 58 Application.launch(); 59 } 60 61 @Override 62 public void start(Stage s) throws Exception { 63 s1 = s; 64 Label lb_net = new Label("网名："); 65 lb_net.setFont(Font.font(17));// 设置字体大小 66 tf_name = new TextField("JDR"); 67 68 /* 消息记录 */ 69 ta_1 = new TextArea(); 70 ta_1.setPrefSize(400, 200); 71 ScrollPane pane_info = new ScrollPane(ta_1); 72 TitledPane pane_01 = new TitledPane("消息记录", pane_info); 73 /* 发送窗口 */ 74 ta_2 = new TextArea(); 75 ta_2.setPrefSize(400, 100); 76 ScrollPane pane_send = new ScrollPane(ta_2); 77 TitledPane pane_02 = new TitledPane("发送窗口", pane_send); 78 /* 发送和按钮事件 */ 79 Button btn_send = new Button("发送"); 80 btn_send.setOnAction(this::btnSend); 81 /* 关闭和按钮事件 */ 82 Button btn_close = new Button("关闭"); 83 btn_close.setOnAction(this::btnClose); 84 /* 发送图片和按钮事件 */ 85 Button btn_img = new Button("选择图片"); 86 btn_img.setOnAction(this::btnImg); 87 Button btn_preview = new Button("预览图片"); 88 btn_preview.setOnAction(this::btnPreview); 89 /* 窗口抖动 */ 90 Button btn_shake = new Button("窗口抖动"); 91 btn_shake.setOnAction(this::btnShake); 92 /* 按钮大小 */ 93 btn_send.setPrefSize(70, 30); 94 btn_close.setPrefSize(70, 30); 95 /* 按钮的位置 */ 96 AnchorPane.setTopAnchor(btn_close, 350.0); 97 AnchorPane.setLeftAnchor(btn_close, 0.0); 98 AnchorPane.setTopAnchor(btn_send, 350.0); 99 AnchorPane.setLeftAnchor(btn_send, 330.0); 100 AnchorPane.setTopAnchor(btn_img, 224.0); 101 AnchorPane.setLeftAnchor(btn_img, 100.0); 102 AnchorPane.setTopAnchor(btn_preview, 224.0); 103 AnchorPane.setLeftAnchor(btn_preview, 160.0); 104 AnchorPane.setTopAnchor(btn_shake, 224.0); 105 AnchorPane.setLeftAnchor(btn_shake, 220.0); 106 107 AnchorPane.setTopAnchor(lb_net, 20.0); 108 AnchorPane.setLeftAnchor(lb_net, 420.0); 109 AnchorPane.setTopAnchor(tf_name, 20.0); 110 AnchorPane.setLeftAnchor(tf_name, 470.0); 111 112 VBox vb = new VBox(pane_01, pane_02); 113 114 AnchorPane apane = new AnchorPane(vb, btn_send, btn_close, btn_img, btn_preview, btn_shake, lb_net, tf_name); 115 apane.setStyle("-fx-background-color:#FFE4C4");// 设置背景色 116 Scene scene = new Scene(apane); 117 118 s.setOnCloseRequest(event -> { 119 Alert alert = new Alert(Alert.AlertType.CONFIRMATION); 120 alert.setTitle("退出"); 121 alert.setHeaderText("你是否要退出?"); 122 Optional<ButtonType> result = alert.showAndWait(); 123 if (result.get() == ButtonType.OK) { 124 try { 125 socket.leaveGroup(ia); 126 System.exit(0); 127 } catch (IOException e) { 128 e.printStackTrace(); 129 } 130 } else { 131 event.consume(); 132 } 133 }); 134 s.setTitle("JDR的午夜群聊"); 135 s.setScene(scene); 136 s.setHeight(450); 137 s.setWidth(650); 138 s.show(); 139 } 140 141 /* 窗口抖动 */ 142 public void btnShake(ActionEvent enent) { 143 144 try { 145 String msg = "shake"; 146 DatagramPacket p = new DatagramPacket(msg.getBytes(), msg.getBytes().length, ia, 6760); 147 socket.send(p); 148 } catch (IOException e) { 149 // TODO 自动生成的 catch 块 150 e.printStackTrace(); 151 } 152 } 153 154 /* 发送按钮事件 */ 155 public void btnSend(ActionEvent enent) { 156 try { 157 String msg = ta_2.getText(); 158 DatagramPacket p = new DatagramPacket(msg.getBytes(), msg.getBytes().length, ia, 6760); 159 socket.send(p); 160 } catch (IOException e) { 161 // TODO 自动生成的 catch 块 162 e.printStackTrace(); 163 } 164 } 165 166 /* 关闭按钮事件 */ 167 public void btnClose(ActionEvent event) { 168 Alert alert = new Alert(Alert.AlertType.CONFIRMATION); 169 alert.setTitle("退出"); 170 alert.setHeaderText("你是否要退出"); 171 Optional<ButtonType> result = alert.showAndWait(); 172 if (result.get() == ButtonType.OK) { 173 System.exit(0); 174 } else { 175 event.consume(); 176 } 177 } 178 179 /* 发送图片按钮事件 */ 180 public void btnImg(ActionEvent event) { 181 FileChooser fileChooser = new FileChooser(); 182 fileChooser.setTitle("选择你要查看的文件"); 183 File file = fileChooser.showOpenDialog(null); 184 if (file != null) { 185 InputStream in = null; 186 byte data[] = new byte[5]; 187 // 读取图片字节数组 188 try { 189 in = new FileInputStream(file); 190 data = new byte[in.available()]; 191 in.read(data); 192 in.close(); 193 } catch (IOException e) { 194 e.printStackTrace(); 195 } 196 197 try { 198 /* 发送消息，告诉别人你发了图片 */ 199 String str = tf_name.getText() + "说：我给你发了张图片"; 200 DatagramPacket p1 = new DatagramPacket(str.getBytes(), str.getBytes().length, ia, 6760); 201 socket.send(p1); 202 // 对字节数组Base64编码 203 BASE64Encoder encoder = new BASE64Encoder(); 204 socket2 = new MulticastSocket(6770); 205 DatagramPacket p2 = new DatagramPacket(encoder.encode(data).getBytes(), 206 encoder.encode(data).getBytes().length, ia, 6770); 207 socket2.joinGroup(ia); 208 socket2.send(p2); 209 } catch (IOException e) { 210 e.printStackTrace(); 211 } 212 } 213 } 214 215 public void btnPreview(ActionEvent event) { 216 FileChooser fileChooser = new FileChooser(); 217 fileChooser.setTitle("选择你要查看的文件"); 218 File file = fileChooser.showOpenDialog(null); 219 220 if (file != null) { 221 Stage stage = new Stage(); 222 BorderPane root = new BorderPane(); 223 String path = file.getPath().toString(); 224 String str = path.replaceAll("\\\\", "\\\\\\\\"); 225 Image image = new Image("file:" + str); 226 ImageView iv = new ImageView(); 227 iv.setImage(image); 228 root.setCenter(iv); 229 Scene scene = new Scene(root); 230 stage.setScene(scene); 231 stage.setWidth(400); 232 stage.setHeight(400); 233 stage.show(); 234 } 235 } 236 } 237 238 class Image_recive extends Thread { 239 public void run() { 240 byte[] buf = new byte[5]; 241 DatagramPacket recv = new DatagramPacket(buf, buf.length); 242 while (true) { 243 BASE64Decoder decoder = new BASE64Decoder(); 244 try { 245 FX_UDP.socket2.receive(recv); 246 String str = new String(recv.getData(), 0, recv.getLength()); 247 // Base64解码 248 byte[] b = decoder.decodeBuffer(str); 249 for (int i = 0; i < b.length; ++i) { 250 if (b[i] < 0) {// 调整异常数据 251 b[i] += 256; 252 } 253 } 254 // 生成png图片 255 Date day = new Date(); 256 SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss"); 257 String name = df.format(day); 258 OutputStream out = new FileOutputStream("D:/(" + name + ").jpg"); 259 out.write(b); 260 out.flush(); 261 out.close(); 262 } catch (Exception e) { 263 } 264 } 265 } 266 } 267 268 class Private_recive extends Thread { 269 public void run() { 270 byte[] buf = new byte[100]; 271 DatagramPacket recv = new DatagramPacket(buf, buf.length); 272 Date day = new Date(); 273 SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 274 try { 275 while (true) { 276 FX_UDP.socket.receive(recv); 277 String str = new String(recv.getData(), 0, recv.getLength()); 278 /*窗口颤抖*/ 279 if (str.contains("shake")) { 280 try { 281 FX_UDP.s1.setX(50); 282 Thread.sleep(50); 283 // FX_UDP.s1.centerOnScreen(); 284 FX_UDP.s1.setX(450); 285 } catch (InterruptedException e) { 286 // TODO 自动生成的 catch 块 287 e.printStackTrace(); 288 } 289 /*接收表情字符串*/ 290 } else if(str.contains("//")){ 291 Platform.runLater(new Runnable(){ 292 public void run(){ 293 Stage stage = new Stage(); 294 BorderPane bp = new BorderPane(); 295 String[] strs=str.split("//"); 296 String img_name = strs[1]; 297 Image image = new Image("file:表情包/"+img_name+".jpg"); 298 ImageView iv = new ImageView(image); 299 bp.setCenter(iv); 300 Scene scene = new Scene(bp); 301 stage.setTitle("表情"); 302 stage.setScene(scene); 303 stage.centerOnScreen(); 304 stage.show(); 305 } 306 }); 307 /*正常聊天*/ 308 }else { 309 FX_UDP.ta_1.appendText(df.format(day) + "\n"); 310 FX_UDP.ta_1.appendText(str + "\n"); 311 } 312 } 313 } catch (IOException e1) { 314 System.out.println("接受失败"); 315 } 316 } 317 }
验证结果
输入：//00 到 //08 中的任何一个字符串