java实现通讯工具代码的简单介绍

java实现串口通信代码

public static void process() {

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端口则退出循环

break;

}else{

portId=null;

}

}

}

SerialPort serialPort = (SerialPort)portId.open("Serial_Communication", 1000);//打开串口的超时时间为1000ms

serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);//设置串口速率为9600，数据位8位，停止位1们，奇偶校验无

InputStream in = serialPort.getInputStream();//得到输入流

OutputStream out = serialPort.getOutputStream();//得到输出流

//进行输入输出操作

//操作结束后

in.close();

out.close();

serialPort.close();//关闭串口

} catch (PortInUseException e) {

e.printStackTrace();

} catch (UnsupportedCommOperationException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

}

相关问答

Q1: Java Rmi如何实现两个客户端之间的通信 求说的具体点

RMI的开发步骤

先创建远程接口及声明远程方法，注意这是实现双方通讯的接口，需要继承Remote

开发一个类来实现远程接口及远程方法，值得注意的是实现类需要继承UnicastRemoteObject

通过javac命令编译文件，通过java -server 命令注册服务，启动远程对象

最后客户端查找远程对象，并调用远程方法

首先为服务建立一个Model层，注意因为此对象需要现实进行远程传输，所以必须继承Serializable

代码 

package rmi.model;

import java.io.Serializable;

//注意对象必须继承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;

    }

}

创建远程接口PersonService,注意远程接口需要继承Remote

代码

package rmi.service;

import java.rmi.Remote;

import java.rmi.RemoteException;

import java.util.List;

import rmi.model.*;

//此为远程对象调用的接口，必须继承Remote类

publicinterface PersonService extends Remote {

    public ListPersonEntity GetList() throws RemoteException;

}

建立PersonServiceImpl实现远程接口，注意此为远程对象实现类，需要继承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.*;

//此为远程对象的实现类，须继承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;

    }    

}

建立服务器端，在服务器端注册RMI通讯端口与通讯路径，然后通讯javac命令编译文件，通过java -server 命令注册服务。以下面代码为例，如果阁下将项目建立于D:\\RMI\RemotingService文件夹上时，则先输入D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java获取Program.class（如何阁下使用的MyEclipse等开发工具，可跳过此步，直接在*/bin文件夹中直接调用已经生成的Program.class），然后输入D:\\RMI\RemotingService\srcjava rmi/remotingservice/Program启动服务。

代码

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

            //注册通讯端口

            LocateRegistry.createRegistry(6600);

            //注册通讯路径

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

        }

    }

}

最后建立客户端进行测试，注意客户调用的RMI路径必须服务器配置一致

代码 

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{

            //调用远程对象，注意RMI路径与接口必须与服务器配置一致

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

        }

    }

}

常见错误

在命令提示符调用java命令时，显示并无此命令。这是因为未在“环境变量”中绑定JAVA的JDK命令造成的，你首先单击“计算机右键”-“属性”-“高级”-“环境变量”。在系统变量Path设置中加载为JDK的路径  .;D:\Program Files\Genuitec\Common\binary\com.sun.java.jdk.win32.x86_1.6.0.013\bin。然后在ClassPath加载服务器端的Program.class地址 .;D:\\RMI\RemotingService\bin

在调用javac命令时出现“javac 找不到文件 ..... ”此错误，可能是因为阁下输入的文件路径出现错误造成，注意不要把D:\\RMI\RemotingService\srcjavac rmi/remotingservice/Program.java写错为D:\\RMI\RemotingService\srcjavac rmi.remotingservice.Program.java

在调用D:\\RMI\RemotingService\binjava rmi/remotingservice/Program命令时出现“Exception in thread 'main' java.lang.NoClassEdfoundError”错误，第一这可能是阁下把Program错写为Program.class，注意java命令不需要加后缀名。第二可能是阁下把“java rmi/remotingservice/Program”错写为“java rmi\remotingservice\Program"。

Q2: 怎样用java web和websocket实现网页即时通讯

原理

WebSocket protocol 。

现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客户端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求，然而HTTP request 的header是非常长的，里面包含的有用数据可能只是一个很小的值，这样会占用很多的带宽。

而比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信，但依然需要发出请求。

在 WebSocket API，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket 协议中，为我们实现即时服务带来了两大好处：

1. Header

互相沟通的Header是很小的-大概只有 2 Bytes

2. Server Push

服务器的推送，服务器不再被动的接收到浏览器的request之后才返回数据，而是在有新数据时就主动推送给浏览器。

一、项目简介

WebSocket是HTML5一种新的协议，它实现了浏览器与服务器全双工通信，这里就将使用WebSocket来开发网页聊天室，前端框架会使用AmazeUI，后台使用Java，编辑器使用UMEditor。

二、涉及知识点

网页前端（HTML+CSS+JS）和Java

三、软件环境 Tomcat 7 JDK 7 Eclipse JavaEE 现代浏览器

四、效果截图

效果1

效果2

五、项目实战

1. 新建项目

打开Eclipse JavaEE，新建一个名为Chat的Dynamic Web Project，然后导入处理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这几个包放在WebContent/WEB-INF/lib目录下，最后把项目发布到Tomcat服务器上，到此空项目就搭建完成了。

2. 编写前端页面

在WebContent目录下新建一个名为index.jsp的页面，这里使用了AmazeUI框架，它是一个跨屏自适应的前端框架，消息输入框使用了UMEditor，它是一个富文本在线编辑器，能让我们的消息内容多姿多彩。

首先从 AmazeUI官网 下载压缩包，然后解压把assets文件夹拷贝到WebContent目录下，这样我们就能使用AmazeUI了。

再从 UEditer官网 下载Mini版的JSP版本压缩包，解压后把整个目录拷贝到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');   // 使昵称框获取焦点   $('#nickname')[0].focus();  }); /script/body/html  

编写完成之后启动Tomcat服务器，然后访问   ，会看到如下界面。

3. 编写后台代码

新建一个com.shiyanlou.chat的包，在包中创建一个名为ChatServer的类，从JavaEE 7开始就统一了WebSocket的API，因此无论是什么服务器，用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;/** * 聊天服务器类 * @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) {  // 添加初始化操作 } /**  * 接受客户端的消息，并把消息发送给所有连接的会话  * @param message 客户端发来的消息  * @param session 客户端的会话  */ @OnMessage public void getMessage(String message, Session session) {  // 把客户端的消息解析为JSON对象  JSONObject jsonObject = JSONObject.fromObject(message);  // 在消息中添加发送日期  jsonObject.put("date", DATE_FORMAT.format(new Date()));  // 把消息发送给所有连接的会话  for (Session openSession : session.getOpenSessions()) {   // 添加本条消息是否为当前会话本身发的标志   jsonObject.put("isSelf", openSession.equals(session));   // 发送JSON格式的消息   openSession.getAsyncRemote().sendText(jsonObject.toString());  } } @OnClose public void close() {  // 添加关闭会话时的操作 } @OnError public void error(Throwable t) {  // 添加处理错误的操作 }}  

4. 前后台交互

后台写完了，前台要用WebSocket连接后台，需要新建一个WebSocket对象，然后就可以和服务器端进行交互，从浏览器发送消息给服务器端，同时要验证输入框的内容是否为空，然后接受服务端发送的消息，把它们动态地添加到聊天内容框中，在

?

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354    var um = UM.getEditor('myEditor');$('#nickname')[0].focus();// 新建WebSocket对象，最后的/websocket对应服务器端的@ServerEndpoint("/websocket")var socket = new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket');   // 处理服务器端发送的数据   socket.onmessage = function(event) {    addMessage(event.data);   };   // 点击Send按钮时的操作   $('#send').on('click', function() {    var nickname = $('#nickname').val();    if (!um.hasContents()) {    // 判断消息输入框是否为空     // 消息输入框获取焦点     um.focus();     // 添加抖动效果     $('.edui-container').addClass('am-animation-shake');     setTimeout("$('.edui-container').removeClass('am-animation-shake')", 1000);    } else if (nickname == '') {    // 判断昵称框是否为空     //昵称框获取焦点     $('#nickname')[0].focus();     // 添加抖动效果     $('#message-input-nickname').addClass('am-animation-shake');     setTimeout("$('#message-input-nickname').removeClass('am-animation-shake')", 1000);    } else {     // 发送消息     socket.send(JSON.stringify({      content : um.getContent(),      nickname : nickname     }));     // 清空消息输入框     um.setContent('');     // 消息输入框获取焦点     um.focus();    }   });   // 把消息添加到聊天内容中   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"//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');    // 把滚动条滚动到底部    $(".chat-content-container").scrollTop($(".chat-content-container")[0].scrollHeight);   }  

到这步，简单的网页聊天室就完成了，你可以多开几个窗口或在局域网中邀请小伙伴们来一起测试。

六、小结

本次项目课使用WebSocket实现了简单的网页聊天室，其实WebSocket不仅可以应用于浏览器，也可以应用于桌面客户端。