public static void process() {
主要從事網(wǎng)頁設(shè)計(jì)、PC網(wǎng)站建設(shè)（電腦版網(wǎng)站建設(shè)）、wap網(wǎng)站建設(shè)（手機(jī)版網(wǎng)站建設(shè)）、響應(yīng)式網(wǎng)站建設(shè)、程序開發(fā)、微網(wǎng)站、小程序開發(fā)等，憑借多年來在互聯(lián)網(wǎng)的打拼，我們?cè)诨ヂ?lián)網(wǎng)網(wǎng)站建設(shè)行業(yè)積累了豐富的成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、網(wǎng)絡(luò)營銷經(jīng)驗(yàn)，集策劃、開發(fā)、設(shè)計(jì)、營銷、管理等多方位專業(yè)化運(yùn)作于一體，具備承接不同規(guī)模與類型的建設(shè)項(xiàng)目的能力。
try {
Enumeration portList = CommPortIdentifier.getPortIdentifiers();
while (portList.hasMoreElements())
{
CommPortIdentifier portId = (CommPortIdentifier) portList.nextElement();
if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL)//如果端口類型是串口則判斷名稱
{
if(portId.getName().equals("COM1")){//如果是COM1端口則退出循環(huán)
break;
}else{
portId=null;
}
}
}
SerialPort serialPort = (SerialPort)portId.open("Serial_Communication", 1000);//打開串口的超時(shí)時(shí)間為1000ms
serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);//設(shè)置串口速率為9600，數(shù)據(jù)位8位，停止位1們，奇偶校驗(yàn)無
InputStream in = serialPort.getInputStream();//得到輸入流
OutputStream out = serialPort.getOutputStream();//得到輸出流
//進(jìn)行輸入輸出操作
//操作結(jié)束后
in.close();
out.close();
serialPort.close();//關(guān)閉串口
} catch (PortInUseException e) {
e.printStackTrace();
} catch (UnsupportedCommOperationException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
RMI的開發(fā)步驟
先創(chuàng)建遠(yuǎn)程接口及聲明遠(yuǎn)程方法，注意這是實(shí)現(xiàn)雙方通訊的接口，需要繼承Remote
開發(fā)一個(gè)類來實(shí)現(xiàn)遠(yuǎn)程接口及遠(yuǎn)程方法，值得注意的是實(shí)現(xiàn)類需要繼承UnicastRemoteObject
通過javac命令編譯文件，通過java -server 命令注冊(cè)服務(wù)，啟動(dòng)遠(yuǎn)程對(duì)象
最后客戶端查找遠(yuǎn)程對(duì)象，并調(diào)用遠(yuǎn)程方法
首先為服務(wù)建立一個(gè)Model層，注意因?yàn)榇藢?duì)象需要現(xiàn)實(shí)進(jìn)行遠(yuǎn)程傳輸，所以必須繼承Serializable
代碼?
package?rmi.model;
import?java.io.Serializable;
//注意對(duì)象必須繼承Serializable
publicclass?PersonEntity?implements?Serializable?{
privateint?id;
private?String?name;
privateint?age;
publicvoid?setId(int?id)?{
this.id?=?id;
}
publicint?getId()?{
return?id;
}
publicvoid?setName(String?name)?{
this.name?=?name;
}
public?String?getName()?{
return?name;
}
publicvoid?setAge(int?age)?{
this.age?=?age;
}
publicint?getAge()?{
return?age;
}
}
創(chuàng)建遠(yuǎn)程接口PersonService,注意遠(yuǎn)程接口需要繼承Remote
代碼
package?rmi.service;
import?java.rmi.Remote;
import?java.rmi.RemoteException;
import?java.util.List;
import?rmi.model.*;
//此為遠(yuǎn)程對(duì)象調(diào)用的接口，必須繼承Remote類
publicinterface?PersonService?extends?Remote?{
public?ListPersonEntity?GetList()?throws?RemoteException;
}
建立PersonServiceImpl實(shí)現(xiàn)遠(yuǎn)程接口，注意此為遠(yuǎn)程對(duì)象實(shí)現(xiàn)類，需要繼承UnicastRemoteObject
代碼
package?rmi.serviceImpl;
import?java.rmi.RemoteException;
import?java.rmi.server.UnicastRemoteObject;
import?java.util.LinkedList;
import?java.util.List;
import?rmi.model.PersonEntity;
import?rmi.service.*;
//此為遠(yuǎn)程對(duì)象的實(shí)現(xiàn)類，須繼承UnicastRemoteObject
publicclass?PersonServiceImpl?extends?UnicastRemoteObject?implements?PersonService?{
public?PersonServiceImpl()?throws?RemoteException?{
super();
//?TODO?Auto-generated?constructor?stub
}
@Override
public?ListPersonEntity?GetList()?throws?RemoteException?{
//?TODO?Auto-generated?method?stub
System.out.println("Get?Person?Start!");
ListPersonEntity?personList=new?LinkedListPersonEntity();
PersonEntity?person1=new?PersonEntity();
person1.setAge(25);
person1.setId(0);
person1.setName("Leslie");
personList.add(person1);
PersonEntity?person2=new?PersonEntity();
person2.setAge(25);
person2.setId(1);
person2.setName("Rose");
personList.add(person2);
return?personList;
}????
}
建立服務(wù)器端，在服務(wù)器端注冊(cè)RMI通訊端口與通訊路徑，然后通訊javac命令編譯文件，通過java -server 命令注冊(cè)服務(wù)。以下面代碼為例，如果閣下將項(xiàng)目建立于D:\\RMI\RemotingService文件夾上時(shí)，則先輸入D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java獲取Program.class（如何閣下使用的MyEclipse等開發(fā)工具，可跳過此步，直接在*/bin文件夾中直接調(diào)用已經(jīng)生成的Program.class），然后輸入D:\\RMI\RemotingService\srcjava rmi/remotingservice/Program啟動(dòng)服務(wù)。
代碼
package?rmi.remotingservice;
import?java.rmi.Naming;
import?java.rmi.registry.LocateRegistry;
import?rmi.service.*;
import?rmi.serviceImpl.*;
publicclass?Program{
publicstaticvoid?main(String[]?args)?{
try?{
PersonService?personService=new?PersonServiceImpl();
//注冊(cè)通訊端口
LocateRegistry.createRegistry(6600);
//注冊(cè)通訊路徑
Naming.rebind("rmi://127.0.0.1:6600/PersonService",?personService);
System.out.println("Service?Start!");
}?catch?(Exception?e)?{
//?TODO?Auto-generated?catch?block
e.printStackTrace();
}
}
}
最后建立客戶端進(jìn)行測(cè)試，注意客戶調(diào)用的RMI路徑必須服務(wù)器配置一致
代碼?
package?rmi.remotingclient;
import?java.rmi.Naming;
import?java.util.List;
import?rmi.model.PersonEntity;
import?rmi.service.*;
publicclass?Program?{
publicstaticvoid?main(String[]?args){
try{
//調(diào)用遠(yuǎn)程對(duì)象，注意RMI路徑與接口必須與服務(wù)器配置一致
PersonService?personService=(PersonService)Naming.lookup("rmi://127.0.0.1:6600/PersonService");
ListPersonEntity?personList=personService.GetList();
for(PersonEntity?person:personList){
System.out.println("ID:"+person.getId()+"?Age:"+person.getAge()+"?Name:"+person.getName());
}
}catch(Exception?ex){
ex.printStackTrace();
}
}
}
常見錯(cuò)誤
在命令提示符調(diào)用java命令時(shí)，顯示并無此命令。這是因?yàn)槲丛凇碍h(huán)境變量”中綁定JAVA的JDK命令造成的，你首先單擊“計(jì)算機(jī)右鍵”-“屬性”-“高級(jí)”-“環(huán)境變量”。在系統(tǒng)變量Path設(shè)置中加載為JDK的路徑? .;D:\Program Files\Genuitec\Common\binary\com.sun.java.jdk.win32.x86_1.6.0.013\bin。然后在ClassPath加載服務(wù)器端的Program.class地址 .;D:\\RMI\RemotingService\bin
在調(diào)用javac命令時(shí)出現(xiàn)“javac 找不到文件 ..... ”此錯(cuò)誤，可能是因?yàn)殚w下輸入的文件路徑出現(xiàn)錯(cuò)誤造成，注意不要把D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java寫錯(cuò)為D:\\RMI\RemotingService\srcjavac rmi.remotingservice.Program.java
在調(diào)用D:\\RMI\RemotingService\binjava rmi/remotingservice/Program命令時(shí)出現(xiàn)“Exception in thread 'main' java.lang.NoClassEdfoundError”錯(cuò)誤，第一這可能是閣下把Program錯(cuò)寫為Program.class，注意java命令不需要加后綴名。第二可能是閣下把“java rmi/remotingservice/Program”錯(cuò)寫為“java rmi\remotingservice\Program"。
原理
WebSocket protocol 。
現(xiàn)很多網(wǎng)站為了實(shí)現(xiàn)即時(shí)通訊，所用的技術(shù)都是輪詢(polling)。輪詢是在特定的的時(shí)間間隔（如每1秒），由瀏覽器對(duì)服務(wù)器發(fā)出HTTP request，然后由服務(wù)器返回最新的數(shù)據(jù)給客戶端的瀏覽器。這種傳統(tǒng)的HTTP request 的模式帶來很明顯的缺點(diǎn) – 瀏覽器需要不斷的向服務(wù)器發(fā)出請(qǐng)求，然而HTTP request 的header是非常長的，里面包含的有用數(shù)據(jù)可能只是一個(gè)很小的值，這樣會(huì)占用很多的帶寬。
而比較新的技術(shù)去做輪詢的效果是Comet – 用了AJAX。但這種技術(shù)雖然可達(dá)到全雙工通信，但依然需要發(fā)出請(qǐng)求。
在 WebSocket API，瀏覽器和服務(wù)器只需要做一個(gè)握手的動(dòng)作，然后，瀏覽器和服務(wù)器之間就形成了一條快速通道。兩者之間就直接可以數(shù)據(jù)互相傳送。在此WebSocket 協(xié)議中，為我們實(shí)現(xiàn)即時(shí)服務(wù)帶來了兩大好處：
1. Header
互相溝通的Header是很小的-大概只有 2 Bytes
2. Server Push
服務(wù)器的推送，服務(wù)器不再被動(dòng)的接收到瀏覽器的request之后才返回?cái)?shù)據(jù)，而是在有新數(shù)據(jù)時(shí)就主動(dòng)推送給瀏覽器。
一、項(xiàng)目簡介
WebSocket是HTML5一種新的協(xié)議，它實(shí)現(xiàn)了瀏覽器與服務(wù)器全雙工通信，這里就將使用WebSocket來開發(fā)網(wǎng)頁聊天室，前端框架會(huì)使用AmazeUI，后臺(tái)使用Java，編輯器使用UMEditor。
二、涉及知識(shí)點(diǎn)
網(wǎng)頁前端（HTML+CSS+JS）和Java
三、軟件環(huán)境 Tomcat 7 JDK 7 Eclipse JavaEE 現(xiàn)代瀏覽器
四、效果截圖
效果1
效果2
五、項(xiàng)目實(shí)戰(zhàn)
1. 新建項(xiàng)目
打開Eclipse JavaEE，新建一個(gè)名為Chat的Dynamic Web Project，然后導(dǎo)入處理JSON格式字符串所需要的包，把commons-beanutils-1.8.0.jar、commons-collections-3.2.1.jar、commons-lang-2.5.jar、commons-logging-1.1.1.jar、ezmorph-1.0.6.jar和json-lib-2.4-jdk15.jar這幾個(gè)包放在WebContent/WEB-INF/lib目錄下，最后把項(xiàng)目發(fā)布到Tomcat服務(wù)器上，到此空項(xiàng)目就搭建完成了。
2. 編寫前端頁面
在WebContent目錄下新建一個(gè)名為index.jsp的頁面，這里使用了AmazeUI框架，它是一個(gè)跨屏自適應(yīng)的前端框架，消息輸入框使用了UMEditor，它是一個(gè)富文本在線編輯器，能讓我們的消息內(nèi)容多姿多彩。
首先從 AmazeUI官網(wǎng) 下載壓縮包，然后解壓把a(bǔ)ssets文件夾拷貝到WebContent目錄下，這樣我們就能使用AmazeUI了。
再從 UEditer官網(wǎng) 下載Mini版的JSP版本壓縮包，解壓后把整個(gè)目錄拷貝到WebContent目錄下，接下來就可以編寫前端代碼了，代碼如下（你可以按照自己的喜好編寫）：
?
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 ? ?%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%!DOCTYPE htmlhtml lang="zh"headmeta charset="utf-8"meta http-equiv="X-UA-Compatible" content="IE=edge"meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no"titleShiYanLou Chat/title!-- Set render engine for 360 browser --meta name="renderer" content="webkit"!-- No Baidu Siteapp--meta http-equiv="Cache-Control" content="no-siteapp" /link rel="alternate icon" href="assets/i/favicon.ico"link rel="stylesheet" href="assets/css/amazeui.min.css"link rel="stylesheet" href="assets/css/app.css"!-- umeditor css --link href="umeditor/themes/default/css/umeditor.css" rel="stylesheet"style.title {?text-align: center;}.chat-content-container {?height: 29rem;?overflow-y: scroll;?border: 1px solid silver;}/style/headbody?!-- title start --?div class="title"??div class="am-g am-g-fixed"???div class="am-u-sm-12"????h1 class="am-text-primary"ShiYanLou Chat/h1???/div??/div?/div?!-- title end --?!-- chat content start --?div class="chat-content"??div class="am-g am-g-fixed chat-content-container"???div class="am-u-sm-12"????ul id="message-list" class="am-comments-list am-comments-list-flip"/ul???/div??/div?/div?!-- chat content start --?!-- message input start --?div class="message-input am-margin-top"??div class="am-g am-g-fixed"???div class="am-u-sm-12"????form class="am-form"?????div class="am-form-group"??????script type="text/plain" id="myEditor" style="width: 100%;height: 8rem;"/script?????/div????/form???/div??/div??div class="am-g am-g-fixed am-margin-top"???div class="am-u-sm-6"????div id="message-input-nickname" class="am-input-group am-input-group-primary"?????span class="am-input-group-label"i class="am-icon-user"/i/span?????input id="nickname" type="text" class="am-form-field" placeholder="Please enter nickname"/????/div???/div???div class="am-u-sm-6"????button id="send" type="button" class="am-btn am-btn-primary"?????i class="am-icon-send"/i Send????/button???/div??/div?/div?!-- message input end --?!--[if (gte IE 9)|!(IE)]!--?script src="assets/js/jquery.min.js"/script?!--![endif]--?!--[if lte IE 8 ]?script src=""/script?![endif]--?!-- umeditor js --?script charset="utf-8" src="umeditor/umeditor.config.js"/script?script charset="utf-8" src="umeditor/umeditor.min.js"/script?script src="umeditor/lang/zh-cn/zh-cn.js"/script?script??$(function() {???// 初始化消息輸入框???var um = UM.getEditor('myEditor');???// 使昵稱框獲取焦點(diǎn)???$('#nickname')[0].focus();??});?/script/body/html ?
編寫完成之后啟動(dòng)Tomcat服務(wù)器，然后訪問 ? ，會(huì)看到如下界面。
3. 編寫后臺(tái)代碼
新建一個(gè)com.shiyanlou.chat的包，在包中創(chuàng)建一個(gè)名為ChatServer的類，從JavaEE 7開始就統(tǒng)一了WebSocket的API，因此無論是什么服務(wù)器，用Java寫的代碼都是一樣的，代碼如下：
?
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 ? ?package com.shiyanlou.chat;import java.text.SimpleDateFormat;import java.util.Date;import javax.websocket.OnClose;import javax.websocket.OnError;import javax.websocket.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;import net.sf.json.JSONObject;/**?* 聊天服務(wù)器類?* @author shiyanlou?*?*/@ServerEndpoint("/websocket")public class ChatServer {?private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm");? // 日期格式化?@OnOpen?public void open(Session session) {??// 添加初始化操作?}?/**??* 接受客戶端的消息，并把消息發(fā)送給所有連接的會(huì)話??* @param message 客戶端發(fā)來的消息??* @param session 客戶端的會(huì)話??*/?@OnMessage?public void getMessage(String message, Session session) {??// 把客戶端的消息解析為JSON對(duì)象??JSONObject jsonObject = JSONObject.fromObject(message);??// 在消息中添加發(fā)送日期??jsonObject.put("date", DATE_FORMAT.format(new Date()));??// 把消息發(fā)送給所有連接的會(huì)話??for (Session openSession : session.getOpenSessions()) {???// 添加本條消息是否為當(dāng)前會(huì)話本身發(fā)的標(biāo)志???jsonObject.put("isSelf", openSession.equals(session));???// 發(fā)送JSON格式的消息???openSession.getAsyncRemote().sendText(jsonObject.toString());??}?}?@OnClose?public void close() {??// 添加關(guān)閉會(huì)話時(shí)的操作?}?@OnError?public void error(Throwable t) {??// 添加處理錯(cuò)誤的操作?}} ?
4. 前后臺(tái)交互
后臺(tái)寫完了，前臺(tái)要用WebSocket連接后臺(tái)，需要新建一個(gè)WebSocket對(duì)象，然后就可以和服務(wù)器端進(jìn)行交互，從瀏覽器發(fā)送消息給服務(wù)器端，同時(shí)要驗(yàn)證輸入框的內(nèi)容是否為空，然后接受服務(wù)端發(fā)送的消息，把它們動(dòng)態(tài)地添加到聊天內(nèi)容框中，在
?
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 ? ?var um = UM.getEditor('myEditor');$('#nickname')[0].focus();// 新建WebSocket對(duì)象，最后的/websocket對(duì)應(yīng)服務(wù)器端的@ServerEndpoint("/websocket")var socket = new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket');???// 處理服務(wù)器端發(fā)送的數(shù)據(jù)???socket.onmessage = function(event) {????addMessage(event.data);???};???// 點(diǎn)擊Send按鈕時(shí)的操作???$('#send').on('click', function() {????var nickname = $('#nickname').val();????if (!um.hasContents()) {??? // 判斷消息輸入框是否為空?????// 消息輸入框獲取焦點(diǎn)?????um.focus();?????// 添加抖動(dòng)效果?????$('.edui-container').addClass('am-animation-shake');?????setTimeout("$('.edui-container').removeClass('am-animation-shake')", 1000);????} else if (nickname == '') {??? // 判斷昵稱框是否為空?????//昵稱框獲取焦點(diǎn)?????$('#nickname')[0].focus();?????// 添加抖動(dòng)效果?????$('#message-input-nickname').addClass('am-animation-shake');?????setTimeout("$('#message-input-nickname').removeClass('am-animation-shake')", 1000);????} else {?????// 發(fā)送消息?????socket.send(JSON.stringify({??????content : um.getContent(),??????nickname : nickname?????}));?????// 清空消息輸入框?????um.setContent('');?????// 消息輸入框獲取焦點(diǎn)?????um.focus();????}???});???// 把消息添加到聊天內(nèi)容中???function addMessage(message) {????message = JSON.parse(message);????var messageItem = 'li class="am-comment '??????+ (message.isSelf ? 'am-comment-flip' : 'am-comment')??????+ '"'??????+ 'a href="javascript:void(0)" img src="assets/images/'??????+ (message.isSelf ? 'self.png' : 'others.jpg')??????+ '" alt="" width="48" height="48"http://a'??????+ 'divheaderdiv'??????+ 'a href="javascript:void(0)"'??????+ message.nickname + '/a time' + message.date??????+ '/time/div/header'??????+ 'div' + message.content??????+ '/div/div/li';????$(messageItem).appendTo('#message-list');????// 把滾動(dòng)條滾動(dòng)到底部????$(".chat-content-container").scrollTop($(".chat-content-container")[0].scrollHeight);???} ?
到這步，簡單的網(wǎng)頁聊天室就完成了，你可以多開幾個(gè)窗口或在局域網(wǎng)中邀請(qǐng)小伙伴們來一起測(cè)試。
六、小結(jié)
本次項(xiàng)目課使用WebSocket實(shí)現(xiàn)了簡單的網(wǎng)頁聊天室，其實(shí)WebSocket不僅可以應(yīng)用于瀏覽器，也可以應(yīng)用于桌面客戶端。
重慶分公司
重慶分公司
