Java使用串行编程操作继电器

 
首先，我们必须建立一个良好的环境，那是，jdk并且tomcat。如果它不必须是web装了！
还有就是配置，也就是默认的comm.jar ，javax.comm.properties ， win32com.dll这几个文件要放对地方
 
comm.jar放到C:Program Files (x86)Javajdk1.7.0_01jrelibext  同一时候也放到jre同样文件夹下
 
javax.comm.properties放到 C:Program Files (x86)Javajdk1.7.0_01jrelib 也放到jre下
 
win32com.dll放到C:Program Files (x86)Javajdk1.7.0_01jrein也放到jre下
 
同一时候
win32com.dll也放到c:windows下的System32下  也把comm.jar配置到classpath下
 
这个弄好了就是编程序了
 
package com.serial;
 
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;
import java.util.TooManyListenersException;
 
import javax.comm.CommPortIdentifier;
import javax.comm.PortInUseException;
import javax.comm.SerialPort;
import javax.comm.SerialPortEvent;
import javax.comm.SerialPortEventListener;
 
/**
 * @项目名称 :illegalsms
 * @文件名 :SerialPort.java
 * @所在包 :org.serial
 * @功能描写叙述 : 串口类
 * @创建日期 :2012-9-13
 * @改动记录 :
 */
public class DSerialPort implements Runnable, SerialPortEventListener {
 
private String appName = "串口通讯測试";
private int timeout = 2000;// open 端口时的等待时间
private int threadTime = 0;
 
private CommPortIdentifier commPort;
private SerialPort serialPort;
private InputStream inputStream;
private OutputStream outputStream;
 
/**
 * @方法名称 :listPort
 * @功能描写叙述 :列出全部可用的串口
 * @返回值类型 :void
 */
@SuppressWarnings("rawtypes")
public void listPort() {
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
 
System.out.println("now to list all Port of this PC：" + en);
 
while (en.hasMoreElements()) {
cpid = (CommPortIdentifier) en.nextElement();
if (cpid.getPortType() == CommPortIdentifier.PORT_SERIAL) {
System.out.println(cpid.getName() + ", "
+ cpid.getCurrentOwner());
}
}
}
 
/**
 * @方法名称 :selectPort
 * @功能描写叙述 :选择一个端口，比方：COM1
 * @返回值类型 :void
 * @param portName
 */
@SuppressWarnings("rawtypes")
public void selectPort(String portName) {
 
this.commPort = null;
CommPortIdentifier cpid;
Enumeration en = CommPortIdentifier.getPortIdentifiers();
while (en.hasMoreElements()) {
cpid = (CommPortIdentifier) en.nextElement();
if (cpid.getPortType() == CommPortIdentifier.PORT_SERIAL
&& cpid.getName().equals(portName)) {
this.commPort = cpid;
break;
}
}
 
openPort();
}
 
/**
 * @方法名称 :openPort
 * @功能描写叙述 :打开SerialPort
 * @返回值类型 :void
 */
private void openPort() {
if (commPort == null)
log(String.format("无法找到名字为'%1$s'的串口！", commPort.getName()));
else {
log("端口选择成功，当前端口：" + commPort.getName() + ",如今实例化 SerialPort:");
 
try {
serialPort = (SerialPort) commPort.open(appName, timeout);
log("实例 SerialPort 成功！");
} catch (PortInUseException e) {
throw new RuntimeException(String.format("端口'%1$s'正在使用中！",
commPort.getName()));
}
}
}
 
/**
 * @方法名称 :checkPort
 * @功能描写叙述 :检查端口是否正确连接
 * @返回值类型 :void
 */
private void checkPort() {
if (commPort == null)
throw new RuntimeException("没有选择端口。请使用 "
+ "selectPort(String portName) 方法选择端口");
 
if (serialPort == null) {
throw new RuntimeException("SerialPort 对象无效。");
}
}
 
/**
 * @方法名称 :write
 * @功能描写叙述 :向端口发送数据，请在调用此方法前 先选择端口，并确定SerialPort正常打开！

 * @返回值类型 :void
 * @param message
 */
public void write(String message) {
checkPort();
 
try {
outputStream = new BufferedOutputStream(
serialPort.getOutputStream());
} catch (IOException e) {
throw new RuntimeException("获取端口的OutputStream出错：" + e.getMessage());
}
 
try {
outputStream.write(message.getBytes());
log("信息发送成功！
");
} catch (IOException e) {
throw new RuntimeException("向端口发送信息时出错：" + e.getMessage());
} finally {
try {
outputStream.close();
} catch (Exception e) {
}
}
}
 
/**
 * @方法名称 :startRead
 * @功能描写叙述 :開始监听从端口中接收的数据
 * @返回值类型 :void
 * @param time
 *            监听程序的存活时间，单位为秒。0 则是一直监听
 */
public void startRead(int time) {
checkPort();
 
try {
inputStream = new BufferedInputStream(serialPort.getInputStream());
} catch (IOException e) {
throw new RuntimeException("获取端口的InputStream出错：" + e.getMessage());
}
 
try {
serialPort.addEventListener(this);
} catch (TooManyListenersException e) {
throw new RuntimeException(e.getMessage());
}
 
serialPort.notifyOnDataAvailable(true);
 
log(String.format("開始监听来自'%1$s'的数据--------------", commPort.getName()));
if (time > 0) {
this.threadTime = time * 10;
Thread t = new Thread(this);
t.start();
log(String.format("监听程序将在%1$d秒后关闭。
。。
。
", threadTime));
}
}
 
/**
 * @方法名称 :close
 * @功能描写叙述 :关闭 SerialPort
 * @返回值类型 :void
 */
public void close() {
serialPort.close();
serialPort = null;
commPort = null;
}
 
public void log(String msg) {
System.out.println(appName + " --> " + msg);
}
 
/**
 * 数据接收的监听处理函数
 */
@Override
public void serialEvent(SerialPortEvent arg0) {
switch (arg0.getEventType()) {
case SerialPortEvent.BI:/* Break interrupt,通讯中断 */
case SerialPortEvent.OE:/* Overrun error，溢位错误 */
case SerialPortEvent.FE:/* Framing error。传帧错误 */
case SerialPortEvent.PE:/* Parity error，校验错误 */
case SerialPortEvent.CD:/* Carrier detect，载波检測 */
case SerialPortEvent.CTS:/* Clear to send，清除发送 */
case SerialPortEvent.DSR:/* Data set ready，数据设备就绪 */
case SerialPortEvent.RI:/* Ring indicator，响铃指示 */
case SerialPortEvent.OUTPUT_BUFFER_EMPTY:/*
 * Output buffer is
 * empty，输出缓冲区清空
 */
break;
case SerialPortEvent.DATA_AVAILABLE:/*
 * Data available at the serial
 * port，端口有可用数据。读到缓冲数组。输出到终端
 */
byte[] readBuffer = new byte[1024];
String readStr = "";
String s2 = "";
 
try {
 
while (inputStream.available() > 0) {
inputStream.read(readBuffer);
readStr += new String(readBuffer).trim();
}
 
s2 = new String(readBuffer).trim();
 
log("接收到端口返回数据(长度为" + readStr.length() + ")：" + readStr);
log(s2);
} catch (IOException e) {
}
}
}
 
@Override
public void run() {
try {
Thread.sleep(threadTime);
serialPort.close();
log(String.format("端口''监听关闭了。", commPort.getName()));
} catch (Exception e) {
e.printStackTrace();
}
}
}
 
 
 
还有就是
 
package com.serial;
 
public class TestSerial {
public static final String PORT_NAME = "COM1";
 
public static void main(String[] args) {
 
DSerialPort sp = new DSerialPort();
 
sp.listPort();
 
sp.selectPort(PORT_NAME);
sp.write("O(00,20,0)E");
sp.startRead(5);
}
}
 
 
要是在web上使用的话   就要建一web serviceproject 
建议用eclipse j2ee版的，然后建一个web项目  
 
 
然后创建同样的类放里面。然后再创建一个servlet
 
package com.serial.servlet;
 
import java.io.IOException;
import java.io.PrintWriter;
 
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
import com.serial.DSerialPort;
 
/**
 * Servlet implementation class RunServlet
 */
public class RunServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
 
/**
 * @see HttpServlet#HttpServlet()
 */
public RunServlet() {
super();
}
 
/**
 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
 *      response)
 */
protected void doGet(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
this.doPost(request, response);
}
 
/**
 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
 *      response)
 */
protected void doPost(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
response.setContentType("text/html");
PrintWriter out = response.getWriter();
 
// String code = "O(00,20,1)E";
String address = request.getParameter("address"); // 地址
String state = request.getParameter("state"); // 状态
String bofile = request.getParameter("file"); // 视频地址
if (address != null && state != null) {
runSerial(address, state, bofile);
} else {
address = "00";
state = "0";
runSerial(address, state, bofile);
}
System.out.println("bofile:" + bofile);
}
 
// 运行串口
public void runSerial(String address, String state, String bofile) {
if (address != null && state != null) {
String PORT_NAME = "COM1";
String code = "O(00," + address + "," + state + ")E";
DSerialPort sp = new DSerialPort();
sp.listPort();
sp.selectPort(PORT_NAME);
sp.write(code);
/* if (bofile != null) { */
if (state.equals("1")) {
play(bofile);
}
/* } */
sp.startRead(1);
 
}
}
 
// 播放视频
public void play(String path) {
System.out.println("path:" + path);
// String
// potplayer="D:/The entertainment software/PotPlayer/PotPlayerMini64.exe";
String mediaPath = "C:/MPlayer_Windows/mplayer/MPlayer.exe"; // 文件路径
// 调用mplayer命令行
String cmd = " -vo directx identify wid String.valueOf(false) -colorkey 0x030303 -slave -osdlevel String.valueOf(1)"
+ " -fullscreen";
try {
Process rn = Runtime.getRuntime().exec(
mediaPath + " " + path + " " + cmd); // 在单独的进程中运行指定命令和变量
 
/*
 * Process rn = Runtime.getRuntime().exec( potplayer + " " + path);
 * // 在单独的进程中运行指定命令和变量
 */
System.out.println("视频開始播放");
} catch (IOException e1) {
e1.printStackTrace();
return;
}
}
}
 
 
我这个是再加了一个播放视频的
 
 说的非常easy，要是有不知道，我可以。我可以来探索哦，QQ在左上角